- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for enqueueAll (1.26 sec)
-
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) -
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)