func()

in pkg/controller/elasticquota.go [143:163]


func (ctrl *ElasticQuotaController) processNextWorkItem() bool {
	keyObj, quit := ctrl.eqQueue.Get()
	if quit {
		return false
	}
	defer ctrl.eqQueue.Done(keyObj)
	key, ok := keyObj.(string)
	if !ok {
		ctrl.eqQueue.Forget(keyObj)
		runtime.HandleError(fmt.Errorf("expected string in workqueue but got %#v", keyObj))
		return true
	}
	if err := ctrl.syncHandler(key); err != nil {
		runtime.HandleError(err)
		klog.Errorf("error syncing elastic quota %q: %s", key, err.Error())
		return true
	}
	ctrl.eqQueue.Forget(keyObj)
	klog.V(5).Infof("Successfully synced %s", key)
	return true
}