// Run update from mizar cluster
Run update from mizar cluster
// Run update from mizar cluster
func (c *MizarArktosNetworkController) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer c.queue.ShutDown()
	defer klog.Info("shutting down mizar arktos network controller")
	klog.Info("Starting Mizar arktos network controller")
	if !cache.WaitForCacheSync(stopCh, c.networkListerSynced) {
		klog.Error("failed to wait for cache to sync")
		return
	}
	for i := 0; i < workers; i++ {
		go wait.Until(c.worker, time.Second, stopCh)
	}
	<-stopCh
}
func ( c * MizarArktosNetworkController ) Run ( workers int , stopCh <- chan struct { } ) { defer utilruntime . HandleCrash ( ) defer c . queue . ShutDown ( ) defer klog . Info ( " " ) klog . Info ( " " ) if ! cache . WaitForCacheSync ( stopCh , c . networkListerSynced ) { klog . Error ( " " ) return } for i := 0 ; i < workers ; i ++ { go wait . Until ( c . worker , time . Second , stopCh ) } <- stopCh }
Run update from mizar cluster
Run update from mizar cluster