func (tcc *Controller) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer tcc.queue.ShutDown()

	klog.Info("Starting tikvcluster controller")
	defer klog.Info("Shutting down tikvcluster controller")

	for i := 0; i < workers; i++ {
		go wait.Until(tcc.worker, time.Second, stopCh)
	}

	<-stopCh
}
// Run runs the tikvcluster controller.
Run runs the tikvcluster controller.
// Run runs the tikvcluster controller .
func (tcc *Controller) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer tcc.queue.ShutDown()
	klog.Info("Starting tikvcluster controller")
	defer klog.Info("Shutting down tikvcluster controller")
	for i := 0; i < workers; i++ {
		go wait.Until(tcc.worker, time.Second, stopCh)
	}
	<-stopCh
}
func ( tcc * Controller ) Run ( workers int , stopCh <- chan struct { } ) { defer utilruntime . HandleCrash ( ) defer tcc . queue . ShutDown ( ) klog . Info ( " " ) defer klog . Info ( " " ) for i := 0 ; i < workers ; i ++ { go wait . Until ( tcc . worker , time . Second , stopCh ) } <- stopCh }
Run runs the tikvcluster controller.
Run runs the tikvcluster controller .