Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newBackoffStore (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top