}
var err error
+
now := l.clock()
if date == "" {
date = now.Format(time.RFC3339Nano)
}
var message Message
+
err = json.Unmarshal(line, &message)
if err != nil {
return Message{}, fmt.Errorf("decode message %d: %w", id, err)
return l.journal.Scan(ctx, start, func(line []byte, place Position) error {
var message Message
+
err := json.Unmarshal(line, &message)
if err != nil {
- return err
+ return fmt.Errorf("decode log message: %w", err)
}
if message.ID != l.index.count {