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
}