Home
last modified time | relevance | path

Searched refs:RateLimiter (Results 76 – 100 of 1467) sorted by relevance

12345678910>>...59

/dports/net-mgmt/thanos/thanos-0.11.0/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/client-go/client-go-0.21.1/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/net/traefik/traefik-2.6.1/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/doctl/doctl-1.68.0/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/service-apis/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/www/grafana8/grafana-8.3.6/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/sysutils/terraform/terraform-1.0.11/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
77 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
85 func DefaultItemBasedRateLimiter() RateLimiter {
134 var _ RateLimiter = &ItemFastSlowRateLimiter{}
136 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
176 limiters []RateLimiter
191 func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter { argument
/dports/security/vault/vault-1.8.2/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemBucketRateLimiter{}
123 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
125 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
133 func DefaultItemBasedRateLimiter() RateLimiter {
182 var _ RateLimiter = &ItemFastSlowRateLimiter{}
184 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
224 limiters []RateLimiter
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/client-go/util/workqueue/
H A Ddefault_rate_limiters.go27 type RateLimiter interface { interface
39 func DefaultControllerRateLimiter() RateLimiter {
52 var _ RateLimiter = &BucketRateLimiter{}
75 var _ RateLimiter = &ItemBucketRateLimiter{}
123 var _ RateLimiter = &ItemExponentialFailureRateLimiter{}
125 …NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter {
133 func DefaultItemBasedRateLimiter() RateLimiter {
182 var _ RateLimiter = &ItemFastSlowRateLimiter{}
184 …c NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter {
224 limiters []RateLimiter
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/plugin/pkg/admission/eventratelimit/
H A Dcache.go27 get(key interface{}) flowcontrol.RateLimiter
33 rateLimiter flowcontrol.RateLimiter
36 func (c *singleCache) get(key interface{}) flowcontrol.RateLimiter {
43 rateLimiterFactory func() flowcontrol.RateLimiter
48 func (c *lruCache) get(key interface{}) flowcontrol.RateLimiter {
55 return value.(flowcontrol.RateLimiter)
/dports/net/storj/storj-1.45.3/private/web/
H A Dratelimiter.go25 type RateLimiter struct { struct
39 func NewIPRateLimiter(config RateLimiterConfig) *RateLimiter {
44 …ewRateLimiter(config RateLimiterConfig, keyFunc func(*http.Request) (string, error)) *RateLimiter {
45 return &RateLimiter{
53 func (rl *RateLimiter) Run(ctx context.Context) { argument
67 func (rl *RateLimiter) cleanupLimiters() { argument
78 func (rl *RateLimiter) Limit(next http.Handler) http.Handler { argument
115 func (rl *RateLimiter) getUserLimit(key string) *rate.Limiter { argument
152 func (rl *RateLimiter) Burst() int { argument
157 func (rl *RateLimiter) Duration() time.Duration { argument
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/channels/
H A DRateLimiter.h26 class RateLimiter : public std::enable_shared_from_this<RateLimiter> {
28 static std::shared_ptr<RateLimiter> create(size_t maxConcurrent);
32 explicit Token(std::shared_ptr<RateLimiter> rateLimiter);
41 std::shared_ptr<RateLimiter> rateLimiter_;
50 explicit RateLimiter(size_t maxConcurrent);
/dports/devel/py-ratelimiter/ratelimiter-1.2.0.post0/tests/
H A Dtest_ratelimiter.py21 from ratelimiter import RateLimiter
55 self.assertRaises(ValueError, RateLimiter, -1, self.period)
56 self.assertRaises(ValueError, RateLimiter, +1, -self.period)
60 obj = RateLimiter(self.max_calls, self.period)
75 obj = RateLimiter(self.max_calls, self.period)
84 @RateLimiter(self.max_calls, self.period)
100 @RateLimiter(self.max_calls, self.period)
113 obj = RateLimiter(self.max_calls, self.period)
121 @RateLimiter(self.max_calls, self.period)
/dports/www/typo3-11/typo3_src-11.5.7/vendor/symfony/rate-limiter/Policy/
H A DSlidingWindowLimiter.php12 namespace Symfony\Component\RateLimiter\Policy;
16 use Symfony\Component\RateLimiter\Exception\ReserveNotSupportedException;
17 use Symfony\Component\RateLimiter\LimiterInterface;
18 use Symfony\Component\RateLimiter\RateLimit;
19 use Symfony\Component\RateLimiter\Reservation;
20 use Symfony\Component\RateLimiter\Storage\StorageInterface;
21 use Symfony\Component\RateLimiter\Util\TimeUtil;

12345678910>>...59