Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for enqueueAfter (0.12 sec)

  1. pkg/controller/ttlafterfinished/ttlafterfinished_controller.go

    	key, err := controller.KeyFunc(job)
    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", job, err))
    		return
    	}
    
    	tc.queue.Add(key)
    }
    
    func (tc *Controller) enqueueAfter(job *batch.Job, after time.Duration) {
    	key, err := controller.KeyFunc(job)
    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", job, err))
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 23:59:28 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. pkg/controller/deployment/progress.go

    	// Add a second to avoid milliseconds skew in AddAfter.
    	// See https://github.com/kubernetes/kubernetes/issues/39785#issuecomment-279959133 for more info.
    	dc.enqueueAfter(d, after+time.Second)
    	return after
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 11:00:44 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  3. pkg/controller/deployment/deployment_controller.go

    		utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", deployment, err))
    		return
    	}
    
    	dc.queue.AddRateLimited(key)
    }
    
    // enqueueAfter will enqueue a deployment after the provided amount of time.
    func (dc *DeploymentController) enqueueAfter(deployment *apps.Deployment, after time.Duration) {
    	key, err := controller.KeyFunc(deployment)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
Back to top