[debug] add blocks added removed debugging

RishabhSaini · RishabhSaini · commit ce03576421e0 · 2026-02-28T03:19:15.000-05:00
diff --git a/pkg/kvevents/pool.go b/pkg/kvevents/pool.go
@@ -386,6 +386,11 @@ func (p *Pool) digestEvents(ctx context.Context, msg *Message, events []event) {
 						"podIdentifier", podIdentifier, "event", ev)
 					continue // Continue processing other events even if one fails
 				}
+				debugLogger.V(1).Info("Added blocks to index",
+					"engineKeys", engineKeys,
+					"parentRequestKey", parentRequestKey,
+					"podIdentifier", podIdentifier,
+					"blockCount", len(engineKeys))
 			}
 
 		case BlockRemoved:
@@ -412,6 +417,9 @@ func (p *Pool) digestEvents(ctx context.Context, msg *Message, events []event) {
 						"podIdentifier", podIdentifier, "event", ev)
 					continue // Continue processing other events even if one fails
 				}
+				debugLogger.V(1).Info("Removed block from index",
+					"engineKey", engineKey,
+					"podIdentifier", podIdentifier)
 			}
 		case AllBlocksCleared:
 			continue

Original file line number	Diff line number	Diff line change
`@@ -386,6 +386,11 @@ func (p Pool) digestEvents(ctx context.Context, msg Message, events []event) {`
`386`	`386`	`"podIdentifier", podIdentifier, "event", ev)`
`387`	`387`	`continue // Continue processing other events even if one fails`
`388`	`388`	`}`
	`389`	`+ debugLogger.V(1).Info("Added blocks to index",`
	`390`	`+ "engineKeys", engineKeys,`
	`391`	`+ "parentRequestKey", parentRequestKey,`
	`392`	`+ "podIdentifier", podIdentifier,`
	`393`	`+ "blockCount", len(engineKeys))`
`389`	`394`	`}`
`390`	`395`
`391`	`396`	`case BlockRemoved:`
`@@ -412,6 +417,9 @@ func (p Pool) digestEvents(ctx context.Context, msg Message, events []event) {`
`412`	`417`	`"podIdentifier", podIdentifier, "event", ev)`
`413`	`418`	`continue // Continue processing other events even if one fails`
`414`	`419`	`}`
	`420`	`+ debugLogger.V(1).Info("Removed block from index",`
	`421`	`+ "engineKey", engineKey,`
	`422`	`+ "podIdentifier", podIdentifier)`
`415`	`423`	`}`
`416`	`424`	`case AllBlocksCleared:`
`417`	`425`	`continue`