// Run begins watching and handling.
Run begins watching and handling.
// Run begins watching and handling .
func (c *MizarPodController) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer c.queue.ShutDown()
	klog.Infof("Starting %v controller", controllerForMizarPod)
	defer klog.Infof("Shutting down %v controller", controllerForMizarPod)
	if !controller.WaitForCacheSync(controllerForMizarPod, stopCh, c.listerSynced, c.networkListerSynced) {
		return
	}
	for i := 0; i < workers; i++ {
		go wait.Until(c.worker, time.Second, stopCh)
	}
	<-stopCh
}
func ( c * MizarPodController ) Run ( workers int , stopCh <- chan struct { } ) { defer utilruntime . HandleCrash ( ) defer c . queue . ShutDown ( ) klog . Infof ( " " , controllerForMizarPod ) defer klog . Infof ( " " , controllerForMizarPod ) if ! controller . WaitForCacheSync ( controllerForMizarPod , stopCh , c . listerSynced , c . networkListerSynced ) { return } for i := 0 ; i < workers ; i ++ { go wait . Until ( c . worker , time . Second , stopCh ) } <- stopCh }
Run begins watching and handling.
Run begins watching and handling .