OPTIM/MINOR: schedule: wait until last command is done, before starting they new refresh cycle

Author: oktalz

pkg/controller/monitor.go

@@ -37,6 +37,9 @@ func (c *HAProxyController) SyncData() {
 			if hadChanges || instance.NeedReload() {
 				c.updateHAProxy()
 				hadChanges = false
+				if job.EventProcessed != nil {
+					close(job.EventProcessed)
+				}
 				continue
 			}
 		case k8ssync.CR_GLOBAL:

pkg/k8s/main.go

@@ -172,7 +172,12 @@ func (k k8s) MonitorChanges(eventChan chan k8ssync.SyncDataEvent, stop chan stru
 	logger.Debugf("Executing syncPeriod every %s", syncPeriod.String())
 	for {
 		time.Sleep(syncPeriod)
-		eventChan <- k8ssync.SyncDataEvent{SyncType: k8ssync.COMMAND}
+		ep := make(chan struct{})
+		eventChan <- k8ssync.SyncDataEvent{
+			SyncType:       k8ssync.COMMAND,
+			EventProcessed: ep,
+		}
+		<-ep
 	}
 }