ensure hearbeats are sent during sync done for add/delete/update even…

…ts of service, endpoints Fixes #879
cloudnativelabs · May 4, 2020 · e04ac66 · e04ac66
1 parent f3ea1a6
commit e04ac66
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/controllers/proxy/network_services_controller.go b/pkg/controllers/proxy/network_services_controller.go
@@ -375,6 +375,7 @@ func (nsc *NetworkServicesController) Run(healthChan chan<- *healthcheck.Control
 			}
 
 		case perform := <-nsc.syncChan:
+			healthcheck.SendHeartBeat(healthChan, "NSC")
 			switch perform {
 			case synctypeAll:
 				glog.V(1).Info("Performing requested full sync of services")
@@ -391,6 +392,9 @@ func (nsc *NetworkServicesController) Run(healthChan chan<- *healthcheck.Control
 					glog.Errorf("Error during ipvs sync in network service controller. Error: " + err.Error())
 				}
 			}
+			if err == nil {
+				healthcheck.SendHeartBeat(healthChan, "NSC")
+			}
 
 		case <-t.C:
 			glog.V(1).Info("Performing periodic sync of ipvs services")