Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AddAfter (0.11 sec)

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