Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for TypedBucketRateLimiter (0.31 sec)

  1. 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)
Back to top