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