/dports/net-mgmt/thanos/thanos-0.11.0/vendor/k8s.io/client-go/util/workqueue/ |
H A D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | default_rate_limiters.go | 27 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 D | cache.go | 27 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 D | ratelimiter.go | 25 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 D | RateLimiter.h | 26 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 D | test_ratelimiter.py | 21 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 D | SlidingWindowLimiter.php | 12 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;
|