- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 271 for limiter (0.13 sec)
-
pkg/kubelet/apis/grpc/ratelimit.go
func LimiterUnaryServerInterceptor(limiter Limiter) grpc.UnaryServerInterceptor { return func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) { if !limiter.Allow() { return nil, ErrorLimitExceeded } return handler(ctx, req) } } // WithRateLimiter creates new rate limiter with unary interceptor.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 07:22:23 UTC 2023 - 1.9K bytes - Viewed (0) -
fastapi/concurrency.py
# since we're creating a new limiter for each call, any non-zero limit # works (1 is arbitrary) exit_limiter = CapacityLimiter(1) try: yield await run_in_threadpool(cm.__enter__) except Exception as e: ok = bool( await anyio.to_thread.run_sync( cm.__exit__, type(e), e, None, limiter=exit_limiter ) )
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon Dec 25 17:57:35 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/controller/podautoscaler/rate_limiters.go
return 1 } // Forget indicates that an item is finished being retried. func (r *FixedItemIntervalRateLimiter) Forget(item string) { } // NewDefaultHPARateLimiter creates a rate limiter which limits overall (as per the // default controller rate limiter), as well as per the resync interval func NewDefaultHPARateLimiter(interval time.Duration) workqueue.TypedRateLimiter[string] { return NewFixedItemIntervalRateLimiter(interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
// rate limiter controls the rate limit of the creation of the configmap. // this is useful in multi-apiserver cluster to prevent config existing in a // cluster with mixed enabled/disabled controllers. otherwise, those // apiservers will fight to create/delete until all apiservers are enabled // or disabled. creationRatelimiter *rate.Limiter clock clock.Clock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
src/runtime/timestub.go
// but widely used packages access it using linkname. // Notable members of the hall of shame include: // - gitee.com/quant1x/gox // - github.com/phuslu/log // - github.com/sethvargo/go-limiter // - github.com/ulule/limiter/v3 // // Do not remove or change the type signature. // See go.dev/issue/67401. // //go:linkname time_now time.now func time_now() (sec int64, nsec int32, mono int64) { sec, nsec = walltime()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 889 bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
/** * A TimeLimiter implementation which actually does not attempt to limit time at all. This may be * desirable to use in some unit tests. More importantly, attempting to debug a call which is * time-limited would be extremely annoying, so this gives you a time-limiter you can easily swap in * for your real time-limiter while you're debugging. * * @author Kevin Bourrillion * @author Jens Nyman * @since 1.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
/** * A TimeLimiter implementation which actually does not attempt to limit time at all. This may be * desirable to use in some unit tests. More importantly, attempting to debug a call which is * time-limited would be extremely annoying, so this gives you a time-limiter you can easily swap in * for your real time-limiter while you're debugging. * * @author Kevin Bourrillion * @author Jens Nyman * @since 1.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
m.tlock.RLock() defer m.tlock.RUnlock() return m.bucketsThrottle[opts] } // SetBandwidthLimit sets the bandwidth limit for a bucket func (m *Monitor) SetBandwidthLimit(bucket, arn string, limit int64) { m.tlock.Lock() defer m.tlock.Unlock() limitBytes := limit / int64(m.NodeCount) throttle, ok := m.bucketsThrottle[BucketOptions{Name: bucket, ReplicationARN: arn}] if !ok { throttle = &bucketThrottle{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
CACertNamespaceConfigMap = "istio-ca-root-cert" // maxRetries is the number of times a namespace will be retried before it is dropped out of the queue. // With the current rate-limiter in use (5ms*2^(maxRetries-1)) the following numbers represent the // sequence of delays between successive queuing of a namespace. // // 5ms, 10ms, 20ms, 40ms, 80ms maxRetries = 5 )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
// 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "certificate", }, ), handler: handler, } // Manage the addition/update of certificate requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0)