- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for AddAfter (0.11 sec)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/BuildableDOMCategory.groovy
} } public static void addBefore(Element sibling, Node n) { def parent = sibling.parentNode parent.insertBefore(n, sibling) } public static Object addAfter(Element sibling, Closure cl) { DomBuilder builder = new DomBuilder(sibling.ownerDocument, null) cl.delegate = builder cl.call() def parent = sibling.parentNode
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Aug 11 15:32:19 UTC 2022 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
), } ec.syncFn = ec.sync return ec } // QueueCRD adds CRD into the establishing queue. func (ec *EstablishingController) QueueCRD(key string, timeout time.Duration) { ec.queue.AddAfter(key, timeout) } // Run starts the EstablishingController. func (ec *EstablishingController) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer ec.queue.ShutDown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
return } // delay processing namespace events to allow HA api servers to observe namespace deletion, // and HA etcd servers to observe last minute object creations inside the namespace nm.queue.AddAfter(key, namespaceDeletionGracePeriod) } // worker processes the queue of namespace objects. // Each namespace can be in the queue at most once. // The system ensures that no two workers can process
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
if err != nil { return err } now := c.clock.Now() if !exists { r := c.creationRatelimiter.ReserveN(now, 1) if delay := r.DelayFrom(now); delay > 0 { c.queue.AddAfter(queueKey, delay) r.CancelAt(now) return nil } if _, err = c.configMapClient.ConfigMaps(metav1.NamespaceSystem).Create(context.TODO(), &corev1.ConfigMap{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
return } for key := range services { c.serviceQueue.AddAfter(key, c.endpointUpdatesBatchPeriod) } } func (c *Controller) updatePod(old, cur interface{}) { services := endpointsliceutil.GetServicesToUpdateOnPodChange(c.serviceLister, old, cur) for key := range services { c.serviceQueue.AddAfter(key, c.endpointUpdatesBatchPeriod) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
logger.V(2).Info("StatefulSet will be enqueued after minReadySeconds for availability check", "statefulSet", klog.KObj(set), "minReadySeconds", set.Spec.MinReadySeconds) // Add a second to avoid milliseconds skew in AddAfter. // See https://github.com/kubernetes/kubernetes/issues/39785#issuecomment-279959133 for more info. ssc.enqueueSSAfter(set, (time.Duration(set.Spec.MinReadySeconds)*time.Second)+time.Second) } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/deployment/progress.go
return time.Duration(0) } logger.V(4).Info("Queueing up deployment for a progress check", "deployment", klog.KObj(d), "queueAfter", int(after.Seconds())) // Add a second to avoid milliseconds skew in AddAfter. // See https://github.com/kubernetes/kubernetes/issues/39785#issuecomment-279959133 for more info. dc.enqueueAfter(d, after+time.Second) return after
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
key, err := controller.KeyFunc(rs) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", rs, err)) return } rsc.queue.AddAfter(key, duration) } func (rsc *ReplicaSetController) addRS(logger klog.Logger, obj interface{}) { rs := obj.(*apps.ReplicaSet) logger.V(4).Info("Adding", "replicaSet", klog.KObj(rs)) rsc.enqueueRS(rs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
key, err := controller.KeyFunc(job) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", job, err)) return } tc.queue.AddAfter(key, after) } func (tc *Controller) worker(ctx context.Context) { for tc.processNextWorkItem(ctx) { } } func (tc *Controller) processNextWorkItem(ctx context.Context) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0)