ratelimiter

Documentation

Index

• Constants
• func NewDefaultManagedRateLimiter(provider ratelimiter.RateLimiter) ratelimiter.RateLimiter
• func NewDefaultProviderRateLimiter(rps int) *workqueue.BucketRateLimiter
• func NewGlobal(rps int) *workqueue.BucketRateLimiter

Constants

const (
	// DefaultProviderRPS is the recommended default average requeues per
	// second tolerated by a Crossplane provider.
	DefaultProviderRPS = 1
)

Functions

func NewDefaultManagedRateLimiter

func NewDefaultManagedRateLimiter(provider ratelimiter.RateLimiter) ratelimiter.RateLimiter

NewDefaultManagedRateLimiter returns a rate limiter that takes the maximum delay between the passed provider and a per-item exponential backoff limiter. The exponential backoff limiter has a base delay of 1s and a maximum of 60s.

func NewDefaultProviderRateLimiter

func NewDefaultProviderRateLimiter(rps int) *workqueue.BucketRateLimiter

NewDefaultProviderRateLimiter 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 is a linear function of the requeues per second.

func NewGlobal

func NewGlobal(rps int) *workqueue.BucketRateLimiter

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.