Skip to content

Commit 4a1945e

Browse files
committed
revert & tweak
1 parent 35c3415 commit 4a1945e

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

internal/verifier/change_stream.go

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -324,7 +324,7 @@ func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
324324
}
325325

326326
func addUnixTimeToLogEvent[T constraints.Integer](unixTime T, event *zerolog.Event) *zerolog.Event {
327-
return event.Time("clockTime", time.Unix(int64(unixTime), int64(0)))
327+
return event.Time("timestamp", time.Unix(int64(unixTime), int64(0)))
328328
}
329329

330330
func (v *Verifier) getChangeStreamMetadataCollection() *mongo.Collection {
@@ -333,10 +333,6 @@ func (v *Verifier) getChangeStreamMetadataCollection() *mongo.Collection {
333333

334334
func (verifier *Verifier) loadChangeStreamResumeToken(ctx context.Context) (bson.Raw, error) {
335335
coll := verifier.getChangeStreamMetadataCollection()
336-
verifier.logger.Debug().
337-
Str("db", coll.Database().Name()).
338-
Str("coll", coll.Name()).
339-
Msg("Seeking persisted resume token.")
340336

341337
token, err := coll.FindOne(
342338
ctx,
@@ -364,8 +360,7 @@ func (verifier *Verifier) persistChangeStreamResumeToken(ctx context.Context, cs
364360
if err == nil {
365361
ts, err := extractTimestampFromResumeToken(token)
366362

367-
logEvent := verifier.logger.Debug().
368-
Interface("token", token)
363+
logEvent := verifier.logger.Debug()
369364

370365
if err == nil {
371366
logEvent = addUnixTimeToLogEvent(ts.T, logEvent)

0 commit comments

Comments
 (0)