helpers

Documentation

Index

• type APILimiter
  • func NewAPILimiter(metrics MetricsAPI, rateLimit float64, burst int) *APILimiter
  • func (l *APILimiter) Limit(ctx context.Context, operation string)
• type DelaySimulator
  • func NewDelaySimulator() *DelaySimulator
  • func (d *DelaySimulator) Delay(op Operation)
  • func (d *DelaySimulator) SetDelay(op Operation, delay time.Duration)
• type MetricsAPI
• type Operation

Types

type APILimiter

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

APILimiter allows to rate limit API calls

func NewAPILimiter

func NewAPILimiter(metrics MetricsAPI, rateLimit float64, burst int) *APILimiter

NewAPILimiter returns a new API limiter with the specific rate limit and burst configuration. The MetricsAPI interface is called to allow for metrics accounting.

func (*APILimiter) Limit

func (l *APILimiter) Limit(ctx context.Context, operation string)

Limit applies the rate limiting configuration for the given operation

type DelaySimulator

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

DelaySimulator simulates delays in API calls

func NewDelaySimulator

func NewDelaySimulator() *DelaySimulator

NewDelaySimulator returns a new DelaySimulator

func (*DelaySimulator) Delay

func (d *DelaySimulator) Delay(op Operation)

Delay delays an API operation according to the configuration

func (*DelaySimulator) SetDelay

func (d *DelaySimulator) SetDelay(op Operation, delay time.Duration)

SetDelay specifies the delay to be simulated for an individual API operation

type MetricsAPI

type MetricsAPI interface {
	ObserveRateLimit(operation string, duration time.Duration)
}

MetricsAPI represents the metrics maintained by the API limiter

type Operation

type Operation interface{}

Operation represents an API operation