fix(watcher): handle fatal watcher error

Th3Shadowbroker · Th3Shadowbroker · commit a5ef95d57444 · 2025-07-10T09:19:45.000+02:00
diff --git a/internal/k8s/watcher.go b/internal/k8s/watcher.go
@@ -58,6 +58,8 @@ func NewResourceWatcher(
 			log.Info().Fields(map[string]any{
 				"replayedDocuments": replayedDocuments,
 			}).Msg("Replay from MongoDB successful!")
+		} else {
+			log.Fatal().Err(err).Msg("Watcher failed. Terminating...")
 		}
 	})
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -58,6 +58,8 @@ func NewResourceWatcher(`
`58`	`58`	`log.Info().Fields(map[string]any{`
`59`	`59`	`"replayedDocuments": replayedDocuments,`
`60`	`60`	`}).Msg("Replay from MongoDB successful!")`
	`61`	`+ } else {`
	`62`	`+ log.Fatal().Err(err).Msg("Watcher failed. Terminating...")`
`61`	`63`	`}`
`62`	`64`	`})`
`63`	`65`	`if err != nil {`