Documentation
¶
Overview ¶
Package ratelimiter contains suggested default ratelimiters for providers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LimitRESTConfig ¶
LimitRESTConfig returns a copy of the supplied REST config with rate limits derived from the supplied rate of reconciles per second.
func NewController ¶
func NewController() workqueue.TypedRateLimiter[any]
NewController returns a rate limiter that takes the maximum delay between the passed rate limiter and a per-item exponential backoff limiter. The exponential backoff limiter has a base delay of 1s and a maximum of 60s.
func NewGlobal ¶
func NewGlobal(rps int) *workqueue.TypedBucketRateLimiter[any]
NewGlobal returns a token bucket rate limiter meant for limiting the number of average total requeues per second for all controllers registered with a controller manager. The bucket size (i.e. allowed burst) is rps * 10.
func NewGlobalExponential ¶
Types ¶
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
A Reconciler rate limits an inner, wrapped Reconciler. Requests that are rate limited immediately return RequeueAfter: d without calling the wrapped Reconciler, where d is imposed by the rate limiter.
func New ¶
func New(name string, r reconcile.Reconciler, l workqueue.TypedRateLimiter[any]) *Reconciler
New wraps the supplied Reconciler, ensuring requests are passed to it no more frequently than the supplied RateLimiter allows. Multiple uniquely named Reconcilers can share the same RateLimiter.
Source Files