MINOR: add event processed channel to monitoring

Author: ivanmatmati

pkg/controller/monitor.go

@@ -75,6 +75,10 @@ func (c *HAProxyController) SyncData() {
 			change = c.store.EventPublishService(ns, job.Data.(*store.Service))
 		}
 		hadChanges = hadChanges || change
+		if job.EventProcessed != nil {
+			close(job.EventProcessed)
+		}
+
 	}
 }
 

pkg/k8s/types.go

@@ -7,9 +7,10 @@ type SyncType string
 type SyncDataEvent struct {
 	_ [0]int
 	SyncType
-	Namespace string
-	Name      string
-	Data      interface{}
+	Namespace      string
+	Name           string
+	Data           interface{}
+	EventProcessed chan struct{}
 }
 
 //nolint:golint,stylecheck