- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NewTokenBucketRateLimiter (0.39 sec)
-
plugin/pkg/admission/eventratelimit/cache_test.go
} } } func TestLRUCache(t *testing.T) { rateLimiters := []flowcontrol.RateLimiter{ flowcontrol.NewTokenBucketRateLimiter(1., 1), flowcontrol.NewTokenBucketRateLimiter(2., 2), flowcontrol.NewTokenBucketRateLimiter(3., 3), flowcontrol.NewTokenBucketRateLimiter(4., 4), } nextRateLimiter := 0 rateLimiterFactory := func() flowcontrol.RateLimiter { rateLimiter := rateLimiters[nextRateLimiter]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 08 02:31:37 UTC 2021 - 2.7K bytes - Viewed (0) -
pkg/kubelet/images/helpers.go
if qps == 0.0 { return imageService } return &throttledImageService{ ImageService: imageService, limiter: flowcontrol.NewTokenBucketRateLimiter(qps, burst), } } type throttledImageService struct { kubecontainer.ImageService limiter flowcontrol.RateLimiter }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/clientset.go
if configShallowCopy.Burst <= 0 { return nil, fmt.Errorf("burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0") } configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst) } var cs Clientset var err error cs.crV1, err = crv1.NewForConfigAndClient(&configShallowCopy, httpClient) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 18:26:20 UTC 2022 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/clientset.go
if configShallowCopy.Burst <= 0 { return nil, fmt.Errorf("burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0") } configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst) } var cs Clientset var err error cs.apiextensionsV1, err = apiextensionsv1.NewForConfigAndClient(&configShallowCopy, httpClient) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/scheduler/rate_limited_queue.go
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) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
func NewBackend(delegate audit.Backend, config BatchConfig) audit.Backend { var throttle flowcontrol.RateLimiter if config.ThrottleEnable { throttle = flowcontrol.NewTokenBucketRateLimiter(config.ThrottleQPS, config.ThrottleBurst) } return &bufferedBackend{ delegateBackend: delegate, buffer: make(chan *auditinternal.Event, config.BufferSize), maxBatchSize: config.MaxBatchSize,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
if _, found := nc.zoneStates[zone]; !found { nc.zoneStates[zone] = stateInitial nc.zoneNoExecuteTainter[zone] = scheduler.NewRateLimitedTimedQueue( flowcontrol.NewTokenBucketRateLimiter(nc.evictionLimiterQPS, scheduler.EvictionRateLimiterBurst)) // Init the metric for the new zone. logger.Info("Initializing eviction metric for zone", "zone", zone) evictionsTotal.WithLabelValues(zone).Add(0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)