Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for AddAfter (0.39 sec)

  1. pkg/controller/endpointslice/endpointslice_controller.go

    		return
    	}
    	for key := range services {
    		c.serviceQueue.AddAfter(key, c.endpointUpdatesBatchPeriod)
    	}
    }
    
    func (c *Controller) updatePod(old, cur interface{}) {
    	services := endpointsliceutil.GetServicesToUpdateOnPodChange(c.serviceLister, old, cur)
    	for key := range services {
    		c.serviceQueue.AddAfter(key, c.endpointUpdatesBatchPeriod)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set.go

    			logger.V(2).Info("StatefulSet will be enqueued after minReadySeconds for availability check", "statefulSet", klog.KObj(set), "minReadySeconds", set.Spec.MinReadySeconds)
    			// Add a second to avoid milliseconds skew in AddAfter.
    			// See https://github.com/kubernetes/kubernetes/issues/39785#issuecomment-279959133 for more info.
    			ssc.enqueueSSAfter(set, (time.Duration(set.Spec.MinReadySeconds)*time.Second)+time.Second)
    		}
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
Back to top