code: func (ec *EstablishingController) Run(stopCh <-chan struct{}) {
  	defer utilruntime.HandleCrash()
  	defer ec.queue.ShutDown()
  
  	klog.Infof("Starting EstablishingController")
  	defer klog.Infof("Shutting down EstablishingController")
  
  	if !cache.WaitForCacheSync(stopCh, ec.crdSynced) {
  		return
  	}
  
  	// only start one worker thread since its a slow moving API
  	go wait.Until(ec.runWorker, time.Second, stopCh)
  
  	<-stopCh
  }
docs: // Run starts the EstablishingController.