Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueAll (1.26 sec)

  1. pilot/pkg/config/kube/ingress/status.go

    		// Just sync them all
    		c.enqueueAll()
    	}))
    	// For services, we queue all Ingress if its the ingress service
    	c.services.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) {
    		if o.GetName() == c.meshConfig.Mesh().IngressService && o.GetNamespace() == IngressNamespace {
    			c.enqueueAll()
    		}
    	}))
    	// For pods, we enqueue all Ingress if its part of the ingress service
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  2. pkg/controller/resourcequota/resource_quota_controller.go

    		rq.informerSyncedFuncs = append(rq.informerSyncedFuncs, func() bool {
    			return qm.IsSynced(ctx)
    		})
    	}
    
    	return rq, nil
    }
    
    // enqueueAll is called at the fullResyncPeriod interval to force a full recalculation of quota usage statistics
    func (rq *Controller) enqueueAll(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	defer logger.V(4).Info("Resource quota controller queued all resource quota for full calculation of usage")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top