// Run controller worker which will handle events
Run controller worker which will handle events
// Run controller worker which will handle events
func (c *Controller) Run(stopCh <-chan struct{}) {
	defer runtime.HandleCrash()
	defer c.workqueue.ShutDown()
	klog.Info("starting worker...")
	go wait.Until(c.runWorker, time.Second, stopCh)
	klog.Info("worker started")
	<-stopCh
	klog.Info("stop worker")
}
func ( c * Controller ) Run ( stopCh <- chan struct { } ) { defer runtime . HandleCrash ( ) defer c . workqueue . ShutDown ( ) klog . Info ( " " ) go wait . Until ( c . runWorker , time . Second , stopCh ) klog . Info ( " " ) <- stopCh klog . Info ( " " ) }
Run controller worker which will handle events
Run controller worker which will handle events