add timestamp to Received entry log

tulip · Mar 28, 2024 · b14a21d · b14a21d
1 parent bf16521
commit b14a21d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/oplog/tail.go b/lib/oplog/tail.go
@@ -334,7 +334,8 @@ func (tailer *Tailer) unmarshalEntry(rawData bson.Raw) (timestamp *primitive.Tim
 
 	entries := tailer.parseRawOplogEntry(result, nil)
 	log.Log.Debugw("Received oplog entry",
-		"entry", result)
+		"entry", result,
+		"processTime", time.Now().UnixMilli())
 
 	status := "ignored"
 	database := "(no database)"