- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for SwapLimiter (0.14 sec)
-
pkg/controller/nodelifecycle/scheduler/rate_limited_queue.go
} // Clear removes all items from the queue func (q *RateLimitedTimedQueue) Clear() { q.queue.Clear() } // SwapLimiter safely swaps current limiter for this queue with the // passed one if capacities or qps's differ. func (q *RateLimitedTimedQueue) SwapLimiter(newQPS float32) { q.limiterLock.Lock() defer q.limiterLock.Unlock() if q.limiter.QPS() == newQPS { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 8.2K bytes - Viewed (0)