feat: Replace pure watchers with (Informers + RetryWatchers) [up to you]

cmd/main.go

@@ -61,8 +61,10 @@ func main() {
 	var secureMetrics bool
 	var enableHTTP2 bool
 	var configPath string
-	var eventsPerSecond int
 	var enableWatcherPoolCleaner bool
+	var watcherEventsPerSecond int
+	var informerSecondsToResync int
+	var useWatchers bool
 
 	flag.StringVar(&metricsAddr, "metrics-bind-address", ":8080", "The address the metric endpoint binds to.")
 	flag.StringVar(&probeAddr, "health-probe-bind-address", ":8081", "The address the probe endpoint binds to.")
@@ -74,9 +76,12 @@ func main() {
 	flag.BoolVar(&enableHTTP2, "enable-http2", false,
 		"If set, HTTP/2 will be enabled for the metrics and webhook servers")
 	flag.StringVar(&configPath, "config", "notifik.yaml", "The path to configuration file.")
-	flag.IntVar(&eventsPerSecond, "events-per-second", 20, "Amount of events processed per second (best effort)")
 	flag.BoolVar(&enableWatcherPoolCleaner, "enable-watcher-cleaner", false,
 		"If set, WatcherPool cleaner will be enabled for orphan watchers")
+	flag.IntVar(&watcherEventsPerSecond, "watcher-events-per-second", 20, "Amount of events processed per second by pure watchers (best effort)")
+	flag.IntVar(&informerSecondsToResync, "informer-seconds-to-resync", 300, "Amount of seconds to resync all the objects by informers")
+	flag.BoolVar(&useWatchers, "use-watchers", false,
+		"If set, client-go will use watchers instead of informers (this decreases resiliency saving resources)")
 
 	opts := zap.Options{
 		Development: true,
@@ -185,7 +190,13 @@ func main() {
 	workloadController := xyz.WorkloadController{
 		Client: mgr.GetClient(),
 		Options: xyz.WorkloadControllerOptions{
-			EventsPerSecond: eventsPerSecond,
+			UseWatchers: useWatchers,
+
+			// Options for pure Watchers
+			WatcherEventsPerSecond: watcherEventsPerSecond,
+
+			// Options for Informers
+			InformerSecondsToResync: informerSecondsToResync,
 		},
 	}
 

config/samples/config/notifik.yaml

@@ -7,6 +7,6 @@ integrations:
 
   # (Optional) Configuration parameters to be able to connect with Alertmanager
   alertmanager:
-    url: "https://${TEST_USERNAME}:${TEST_PASSWORD}@webhook.site/d0fd5417-8931-476c-ae6e-c41eda3682af"
+    url: "https://${TEST_USERNAME}:${TEST_PASSWORD}@webhook.site/c78d856d-8cb3-41e8-ae1c-964c6e8bf304"
     headers:
       X-Scope-OrgID: freepik-company

config/samples/notification/alertmanager/notifik_v1alpha1_notification_json.yaml

@@ -24,14 +24,14 @@ spec:
       # The 'key' field admits vitamin Golang templating (well known from Helm)
       # The result of this field will be compared with 'value' for equality
       key: |
-        {{- $source := . -}}
+        {{- $source := .object -}}
         {{- printf "%s" $source.metadata.name -}}
       value: testing
 
   message:
     reason: "NameMatchedAlert"
     data: |
-      {{- $source := . -}}
+      {{- $source := .object -}}
       {{- $now := (now | date "2006-01-02T15:04:05Z07:00") -}}
       {{- $alertStructure := (printf `
         {
@@ -43,7 +43,7 @@ spec:
             },
             "labels": {
               "namespace": "%s",
-              "name": "%s",
+              "name": "%s"
             },
             "generatorURL": "string"
         }` $now $source.metadata.namespace $source.metadata.name) -}}

config/samples/notification/alertmanager/notifik_v1alpha1_notification_yaml.yaml

@@ -24,14 +24,14 @@ spec:
       # The 'key' field admits vitamin Golang templating (well known from Helm)
       # The result of this field will be compared with 'value' for equality
       key: |
-        {{- $source := . -}}
+        {{- $source := .object -}}
         {{- printf "%s" $source.metadata.name -}}
       value: testing
 
   message:
     reason: "NameMatchedAlert"
     data: |
-      {{- $source := . -}}
+      {{- $source := .object -}}
       {{- $now := (now | date "2006-01-02T15:04:05Z07:00") -}}
       {{- $alertStructure := (printf `
         startsAt: "%s"

config/samples/notification/webhook/notifik_v1alpha1_notification.yaml

@@ -25,12 +25,12 @@ spec:
       # The 'key' field admits vitamin Golang templating (well known from Helm)
       # The result of this field will be compared with 'value' for equality
       key: |
-        {{- $source := . -}}
+        {{- $source := .object -}}
         {{- printf "%s" $source.metadata.name -}}
       value: testing
 
   message:
     reason: "NameMatchedAlert"
     data: |
-      {{- $source := . -}}
+      {{- $source := .object -}}
       {{- printf "Hi, I'm on fire: %s/%s" $source.metadata.namespace $source.metadata.name -}}