lock, err := lockFile(filepath.Join(root, "lock"))
if err != nil {
- return nil, err
+ return nil, fmt.Errorf("lock message log: %w", err)
}
l := &Log{
if l.index.count > 0 {
record, _, err := l.index.Read(l.index.count - 1)
if err != nil {
- return err
+ return fmt.Errorf("read last log position: %w", err)
}
last := decodePosition(record)
func (l *Log) Message(id int) (Message, error) {
record, found, err := l.index.Read(id)
if err != nil {
- return Message{}, err
+ return Message{}, fmt.Errorf("read message position: %w", err)
}
if !found {