ratelimit

Documentation

Index

• type GCERateLimiter
  • func NewGCERateLimiter(specs []string, operationPollInterval time.Duration, logger klog.Logger) (*GCERateLimiter, error)
  • func (grl *GCERateLimiter) Accept(ctx context.Context, key *cloud.RateLimitKey) error
  • func (grl *GCERateLimiter) Observe(ctx context.Context, err error, key *cloud.RateLimitKey)

Types

type GCERateLimiter

type GCERateLimiter struct {
	// contains filtered or unexported fields
}

GCERateLimiter implements cloud.RateLimiter

func NewGCERateLimiter

func NewGCERateLimiter(specs []string, operationPollInterval time.Duration, logger klog.Logger) (*GCERateLimiter, error)

NewGCERateLimiter parses the list of rate limiting specs passed in and returns a properly configured cloud.RateLimiter implementation. Expected format of specs: {"[version].[service].[operation],[type],[param1],[param2],..", "..."}

func (*GCERateLimiter) Accept

func (grl *GCERateLimiter) Accept(ctx context.Context, key *cloud.RateLimitKey) error

Accept looks up the associated strategyRateLimiter (if exists) and waits on it. Then it looks up the associated flowcontrol.RateLimiter (if exists) and waits on it.

func (*GCERateLimiter) Observe

func (grl *GCERateLimiter) Observe(ctx context.Context, err error, key *cloud.RateLimitKey)

Observe looks up the associated strategyRateLimiter (if exists) and passes an error there to observe.