Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for DelayFrom (0.07 sec)

  1. pkg/controlplane/controller/legacytokentracking/controller.go

    	obj, exists, err := c.configMapCache.GetByKey(queueKey)
    	if err != nil {
    		return err
    	}
    
    	now := c.clock.Now()
    	if !exists {
    		r := c.creationRatelimiter.ReserveN(now, 1)
    		if delay := r.DelayFrom(now); delay > 0 {
    			c.queue.AddAfter(queueKey, delay)
    			r.CancelAt(now)
    			return nil
    		}
    
    		if _, err = c.configMapClient.ConfigMaps(metav1.NamespaceSystem).Create(context.TODO(), &corev1.ConfigMap{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top