- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for DefaultControllerRateLimiter (0.35 sec)
-
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)