- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for TypedBucketRateLimiter (0.28 sec)
-
pkg/controller/certificates/certificate_controller.go
workqueue.NewTypedItemExponentialFailureRateLimiter[string](200*time.Millisecond, 1000*time.Second), // 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "certificate", }, ), handler: handler, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
workqueue.NewTypedItemExponentialFailureRateLimiter[string](5*time.Millisecond, 60*time.Second), // 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ) } // enqueueNamespace adds an object to the controller work queue // obj could be an *v1.Namespace, or a DeletionFinalStateUnknown item.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// 10 qps, 100 bucket size. This is only for retry speed and its // only the overall factor (not per item). &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "endpoint_slice_mirroring", }, ), workerLoopPeriod: time.Second, }
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
// 10 qps, 100 bucket size. This is only for retry speed and its // only the overall factor (not per item). &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "endpoint_slice", }, ),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
func newTrackingWorkqueue[T comparable]() *trackingWorkqueue[T] { return &trackingWorkqueue[T]{ limiter: workqueue.NewTypedRateLimitingQueue[T](&workqueue.TypedBucketRateLimiter[T]{Limiter: rate.NewLimiter(rate.Inf, 100)}), pendingMap: map[T]struct{}{}, } } func (t *trackingWorkqueue[T]) Add(item T) { t.queue(item) t.limiter.Add(item) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0)