diff --git a/default.nix b/default.nix index dad7ed0c..e5e2f96a 100644 --- a/default.nix +++ b/default.nix @@ -2,7 +2,7 @@ buildGoModule { pname = "oplogtoredis"; - version = "3.3.0"; + version = "3.4.0"; src = builtins.path { path = ./.; }; postInstall = '' diff --git a/lib/oplog/tail.go b/lib/oplog/tail.go index 791abec6..0f62b032 100644 --- a/lib/oplog/tail.go +++ b/lib/oplog/tail.go @@ -340,8 +340,7 @@ func (tailer *Tailer) unmarshalEntry(rawData bson.Raw) (timestamp *primitive.Tim timestamp = &result.Timestamp entries := tailer.parseRawOplogEntry(result, nil) - log.Log.Debugw("Received oplog entry", - "entry", result) + log.Log.Debugw("Received oplog entry", "entry", result, "processTime", time.Now().UnixMilli()) status := "ignored" database := "(no database)"