// Run create, update, delete service on mizar side
Run create, update, delete service on mizar side
// Run create update delete service on mizar side
func (c *MizarServiceController) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer c.queue.ShutDown()
	defer klog.Info("shutting down mizar service controller")
	klog.Infoln("Starting mizar service controller")
	klog.Infoln("Waiting cache to be synced.")
	if ok := cache.WaitForCacheSync(stopCh, c.serviceListerSynced, c.networkListerSynced); !ok {
		klog.Fatalln("Timeout expired during waiting for caches to sync.")
	}
	for i := 0; i < workers; i++ {
		go wait.Until(c.worker, time.Second, stopCh)
	}
	<-stopCh
}
func ( c * MizarServiceController ) Run ( workers int , stopCh <- chan struct { } ) { defer utilruntime . HandleCrash ( ) defer c . queue . ShutDown ( ) defer klog . Info ( " " ) klog . Infoln ( " " ) klog . Infoln ( " " ) if ok := cache . WaitForCacheSync ( stopCh , c . serviceListerSynced , c . networkListerSynced ) ; ! ok { klog . Fatalln ( " " ) } for i := 0 ; i < workers ; i ++ { go wait . Until ( c . worker , time . Second , stopCh ) } <- stopCh }
Run create, update, delete service on mizar side
Run create update delete service on mizar side