- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AddAfter (0.11 sec)
-
pkg/controller/job/job_controller.go
if oldADS == nil || *oldADS != *curADS { passed := jm.clock.Since(curJob.Status.StartTime.Time) total := time.Duration(*curADS) * time.Second // AddAfter will handle total < passed jm.queue.AddAfter(key, total-passed) logger.V(4).Info("job's ActiveDeadlineSeconds updated, will rsync", "key", key, "interval", total-passed) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } // TODO: Handle overlapping controllers better. See comment in ReplicationManager. dsc.queue.AddAfter(key, after) } // getDaemonSetsForPod returns a list of DaemonSets that potentially match the pod. func (dsc *DaemonSetsController) getDaemonSetsForPod(pod *v1.Pod) []*apps.DaemonSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
} }) } } type fakeQueue struct { workqueue.TypedRateLimitingInterface[string] delay time.Duration key interface{} } func (f *fakeQueue) AddAfter(key string, delay time.Duration) { f.delay = delay f.key = key } // this test will take around 61 seconds to complete func TestControllerV2UpdateCronJob(t *testing.T) { tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0)