If metrics are not supported, set metric to -1

Signed-off-by: Davanum Srinivas <[email protected]>

Author: dims

fault-quarantine/pkg/eventwatcher/event_watcher.go

@@ -46,9 +46,9 @@ type EventWatcherInterface interface {
 	Start(ctx context.Context) error
 	SetProcessEventCallback(
 		callback func(
-			ctx context.Context,
-			event *model.HealthEventWithStatus,
-		) *model.Status,
+		ctx context.Context,
+		event *model.HealthEventWithStatus,
+	) *model.Status,
 	)
 	CancelLatestQuarantiningEvents(ctx context.Context, nodeName string) error
 }
@@ -69,9 +69,9 @@ func NewEventWatcher(
 
 func (w *EventWatcher) SetProcessEventCallback(
 	callback func(
-		ctx context.Context,
-		event *model.HealthEventWithStatus,
-	) *model.Status,
+	ctx context.Context,
+	event *model.HealthEventWithStatus,
+) *model.Status,
 ) {
 	w.processEventCallback = callback
 }
@@ -196,9 +196,8 @@ func (w *EventWatcher) updateUnprocessedEventsMetric(ctx context.Context) {
 				metrics.EventBacklogSize.Set(float64(unprocessedCount))
 				slog.Debug("Updated unprocessed events metric", "count", unprocessedCount, "afterObjectID", objID)
 			} else {
-				// If metrics are not supported, set metric to 0 or skip
 				slog.Debug("Change stream watcher does not support metrics")
-				metrics.EventBacklogSize.Set(0)
+				metrics.EventBacklogSize.Set(-1)
 			}
 		}
 	}