- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for DefaultControllerRateLimiter (0.39 sec)
-
pkg/kube/controllers/queue.go
closed: make(chan struct{}), initialSync: atomic.NewBool(false), } for _, o := range options { o(&q) } if q.queue == nil { q.queue = workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()) } q.log = log.WithLabels("controller", q.name) return q } // Add an item to the queue. func (q Queue) Add(item any) { q.queue.Add(item) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
nodeLister: nodeInformer.Lister(), nodesSynced: nodeInformer.Informer().HasSynced, broadcaster: eventBroadcaster, recorder: recorder, queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "cidrallocator_node"), } if allocatorParams.ServiceCIDR != nil { ra.filterOutServiceRange(logger, allocatorParams.ServiceCIDR) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-mirroring-controller"}) metrics.RegisterMetrics() c := &Controller{ client: client, // This is similar to the DefaultControllerRateLimiter, just with a // significantly higher default backoff (1s vs 5ms). This controller // processes events that can require significant EndpointSlice changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
endpointslicemetrics.RegisterMetrics() c := &Controller{ client: client, // This is similar to the DefaultControllerRateLimiter, just with a // significantly higher default backoff (1s vs 5ms). This controller // processes events that can require significant EndpointSlice changes,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0)