limit

Oct 12, 2023

Changes in this version

+ const MetricNameRateLimitError

+ const MetricNameRateLimitRelease

+ const MetricNameRateLimitTake

+ const MetricNameRateLimitThrottle

+ func NewFixedWindowLimiter(backend Incrementer, clock clock.Clock, config FixedWindowConfig, ...) *fixedWindow

+ func NewMetricMiddlewareWithInterfaces(metricWriter metric.Writer) *metricMiddleware

+ type Factory func() (Limiter, error)

+ type FixedWindowConfig struct

+ Cap int

+ Name string

+ Window time.Duration

+ type Incrementer interface

+ Increment func(ctx context.Context, prefix string) (incr *int, ttl *time.Duration, err error)

+ type Invocation interface

+ GetName func() string

+ GetPrefix func() string

+ GetTraceId func() string

+ type Limiter interface

+ Wait func(ctx context.Context, prefix string) error

+ func Chain(ls ...Limiter) (Limiter, error)

+ func ChainFactories(fs ...func() (Limiter, error)) (Limiter, error)

+ func NewLeakyBucketLimiter(name string, rate int) (Limiter, error)

+ func NewUnlimited() Limiter

+ type LimiterWithMiddleware interface

+ WithMiddleware func(...MiddlewareFactory)

+ func NewFixedWindowDdb(ctx context.Context, config cfg.Config, logger log.Logger, ...) (LimiterWithMiddleware, error)

+ func NewFixedWindowRedis(ctx context.Context, config cfg.Config, logger log.Logger, c FixedWindowConfig) (LimiterWithMiddleware, error)

+ func NewFixedWindowRedisWithInterfaces(clock clock.Clock, redis redis.Client, config FixedWindowConfig, ...) LimiterWithMiddleware

+ type Middleware interface

+ OnError func(ctx context.Context, i Invocation)

+ OnRelease func(ctx context.Context, i Invocation)

+ OnTake func(ctx context.Context, i Invocation)

+ OnThrottle func(ctx context.Context, i Invocation)

+ func ChainMiddleware(fs ...MiddlewareFactory) Middleware

+ func NewMetricMiddleware() Middleware

+ type MiddlewareFactory func() Middleware

+ func NewLoggingMiddleware(logger log.Logger) MiddlewareFactory