Add logging for when enqueueing rechecks.

FGasper · FGasper · commit 4de9c7c1cdde · 2024-11-14T10:19:12.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -90,6 +90,10 @@ func (verifier *Verifier) HandleChangeStreamEvents(ctx context.Context, batch []
 		}
 	}
 
+	verifier.logger.Debug().
+		Int("count", len(docIDs)).
+		Msg("Persisting rechecks for change events.")
+
 	return verifier.insertRecheckDocs(ctx, dbNames, collNames, docIDs, dataSizes)
 }
 
diff --git a/internal/verifier/recheck.go b/internal/verifier/recheck.go
@@ -47,6 +47,10 @@ func (verifier *Verifier) InsertFailedCompareRecheckDocs(
 		collNames[i] = collName
 	}
 
+	verifier.logger.Debug().
+		Int("count", len(documentIDs)).
+		Msg("Persisting rechecks for mismatched or missing documents.")
+
 	return verifier.insertRecheckDocs(
 		context.Background(),
 		dbNames,

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,10 @@ func (verifier *Verifier) HandleChangeStreamEvents(ctx context.Context, batch []`
`90`	`90`	`}`
`91`	`91`	`}`
`92`	`92`
	`93`	`+ verifier.logger.Debug().`
	`94`	`+ Int("count", len(docIDs)).`
	`95`	`+ Msg("Persisting rechecks for change events.")`
	`96`	`+`
`93`	`97`	`return verifier.insertRecheckDocs(ctx, dbNames, collNames, docIDs, dataSizes)`
`94`	`98`	`}`
`95`	`99`