Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewFakeNeverRateLimiter (0.19 sec)

  1. pkg/controller/nodelifecycle/scheduler/rate_limited_queue.go

    	q.limiterLock.Lock()
    	defer q.limiterLock.Unlock()
    	if q.limiter.QPS() == newQPS {
    		return
    	}
    	var newLimiter flowcontrol.RateLimiter
    	if newQPS <= 0 {
    		newLimiter = flowcontrol.NewFakeNeverRateLimiter()
    	} else {
    		newLimiter = flowcontrol.NewTokenBucketRateLimiter(newQPS, EvictionRateLimiterBurst)
    
    		// If we're currently waiting on limiter, we drain the new one - this is a good approach when Burst value is 1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 07:50:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/scheduler/rate_limited_queue_test.go

    	if qps != fakeAlways.QPS() {
    		t.Fatalf("QPS does not match create one: %v instead of %v", qps, fakeAlways.QPS())
    	}
    
    	evictor.SwapLimiter(0)
    	qps = evictor.limiter.QPS()
    	fakeNever := flowcontrol.NewFakeNeverRateLimiter()
    	if qps != fakeNever.QPS() {
    		t.Fatalf("QPS does not match create one: %v instead of %v", qps, fakeNever.QPS())
    	}
    
    	createdQPS := float32(5.5)
    	evictor.SwapLimiter(createdQPS)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 17:40:33 UTC 2023
    - 10K bytes
    - Viewed (0)
Back to top