- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newBackoffStore (0.39 sec)
-
pkg/controller/job/backoff_utils.go
b, ok, err := s.store.GetByKey(jobId) if err != nil { return err } if ok { err = s.store.Delete(b) if err != nil { return err } } return nil } func newBackoffStore() *backoffStore { return &backoffStore{ store: cache.NewStore(backoffRecordKeyFunc), } } var backoffRecordKeyFunc = func(obj interface{}) (string, error) { if u, ok := obj.(*backoffRecord); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
key: "key", failuresAfterLastSuccess: 0, }, }, } for name, tc := range testCases { t.Run(name, func(t *testing.T) { backoffRecordStore := newBackoffStore() tc.storeInitializer(backoffRecordStore) newSucceededPods := []*v1.Pod{} newFailedPods := []*v1.Pod{} for _, finishTime := range tc.newSucceededPods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
broadcaster: eventBroadcaster, recorder: eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "job-controller"}), clock: clock, podBackoffStore: newBackoffStore(), } if _, err := jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.addJob(logger, obj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)