- Sort Score
- Result 10 results
- Languages All
Results 11 - 13 of 13 for AddAfter (0.09 sec)
-
pkg/controller/deployment/deployment_controller.go
key, err := controller.KeyFunc(deployment) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", deployment, err)) return } dc.queue.AddAfter(key, after) } // getDeploymentForPod returns the deployment managing the given Pod. func (dc *DeploymentController) getDeploymentForPod(logger klog.Logger, pod *v1.Pod) *apps.Deployment {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
if err != nil && !apierrors.IsNotFound(err) { return err } } // requeue after the grace period r.ipQueue.AddAfter(key, gracePeriod-ipLifetime) return nil } if err != nil { runtime.HandleError(fmt.Errorf("unable to get parent Service for IPAddress %s due to an unknown error: %v", ipAddress, err))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
specificDelay, err := cfgCtlr.syncOne() switch { case err != nil: klog.Error(err) cfgCtlr.configQueue.AddRateLimited(obj) case specificDelay > 0: cfgCtlr.configQueue.AddAfter(obj, specificDelay) default: cfgCtlr.configQueue.Forget(obj) } }(obj) return true } // syncOne does one full synchronization. It reads all the API
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0)