Skip to content

Commit 51a823d

Browse files
committed
revert unintended
1 parent 164068a commit 51a823d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

internal/verifier/change_stream.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ const (
4242
)
4343

4444
type UnknownEventError struct {
45-
Event ParsedEvent
45+
Event *ParsedEvent
4646
}
4747

4848
func (uee UnknownEventError) Error() string {
@@ -90,7 +90,7 @@ func (verifier *Verifier) HandleChangeStreamEvents(ctx context.Context, batch []
9090
dataSizes[i] = len(changeEvent.FullDocument)
9191
}
9292
default:
93-
return UnknownEventError{Event: changeEvent}
93+
return UnknownEventError{Event: &changeEvent}
9494
}
9595
}
9696

@@ -161,7 +161,7 @@ func (verifier *Verifier) readAndHandleOneChangeEventBatch(
161161
}
162162

163163
if err := cs.Decode(&changeEventBatch[eventsRead]); err != nil {
164-
return errors.Wrap(err, "failed to decode change event")
164+
return errors.Wrapf(err, "failed to decode change event to %T", changeEventBatch[eventsRead])
165165
}
166166

167167
eventsRead++

0 commit comments

Comments
 (0)