- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for AddAfter (0.39 sec)
-
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/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)