code: func (r *Reflector) Run(stopCh <-chan struct{}) {
  	klog.V(3).Infof("Starting reflector %v (%s) from %s", r.expectedType, r.resyncPeriod, r.name)
  	wait.Until(func() {
  		if err := r.ListAndWatch(stopCh); err != nil {
  			utilruntime.HandleError(err)
  		}
  	}, r.period, stopCh)
  }
docs: // Run starts a watch and handles watch events. Will restart the watch if it is closed.
  // Run will exit when stopCh is closed.