Rerun ConfigMap Watch after stop

charts/policy-reporter/Chart.yaml

@@ -3,5 +3,5 @@ name: policy-reporter
 description: K8s PolicyReporter watches for wgpolicyk8s.io/v1alpha1.PolicyReport resources. It creates Prometheus Metrics and can send rule validation events to Loki
 
 type: application
-version: 0.5.1
-appVersion: 0.4.1
+version: 0.5.2
+appVersion: 0.4.2

charts/policy-reporter/values.yaml

@@ -15,7 +15,7 @@ metrics:
 image:
   repository: fjogeleit/policy-reporter
   pullPolicy: IfNotPresent
-  tag: 0.4.1
+  tag: 0.4.2
 
 imagePullSecrets: []
 

pkg/kubernetes/config_client.go

@@ -27,18 +27,18 @@ func (c coreClient) GetConfig(ctx context.Context, name string) (*apiv1.ConfigMa
 }
 
 func (c coreClient) WatchConfigs(ctx context.Context, cb ConfigMapCallback) error {
-	watch, err := c.cmClient.Watch(ctx, metav1.ListOptions{})
-	if err != nil {
-		return err
-	}
+	for {
+		watch, err := c.cmClient.Watch(ctx, metav1.ListOptions{})
+		if err != nil {
+			return err
+		}
 
-	for event := range watch.ResultChan() {
-		if cm, ok := event.Object.(*apiv1.ConfigMap); ok {
-			cb(event.Type, cm)
+		for event := range watch.ResultChan() {
+			if cm, ok := event.Object.(*apiv1.ConfigMap); ok {
+				cb(event.Type, cm)
+			}
 		}
 	}
-
-	return nil
 }
 
 func NewCoreClient(kubeconfig, namespace string) (CoreClient, error) {

pkg/kubernetes/report_client.go

@@ -65,8 +65,6 @@ func (c *policyReportClient) WatchClusterPolicyReports(cb report.WatchClusterPol
 				cb(result.Type, c.mapClusterPolicyReport(item.Object))
 			}
 		}
-
-		log.Println("[WARNING] WatchClusterPolicyReports Stops")
 	}
 }
 
@@ -83,8 +81,6 @@ func (c *policyReportClient) WatchPolicyReports(cb report.WatchPolicyReportCallb
 				cb(result.Type, c.mapPolicyReport(item.Object))
 			}
 		}
-
-		log.Println("[WARNING] WatchPolicyReports Stops")
 	}
 }