ratelimit

Documentation

Index

• func Take(ctx context.Context, l Limiter)
• type Limiter
  • func NewLocalLimiter(maximumRPS, burstableRPS int) Limiter
  • func NewRedisLimiter(redisClient *redis.Client, maxRPS int) Limiter
• type Local
  • func (l Local) Take(ctx context.Context) time.Duration
• type Redis
  • func (r Redis) Take(ctx context.Context) time.Duration

Functions

func Take

func Take(ctx context.Context, l Limiter)

Take ..

Types

type Limiter

type Limiter interface {
	Take(context.Context) time.Duration
}

Limiter ..

func NewLocalLimiter

func NewLocalLimiter(maximumRPS, burstableRPS int) Limiter

NewLocalLimiter ..

func NewRedisLimiter

func NewRedisLimiter(redisClient *redis.Client, maxRPS int) Limiter

NewRedisLimiter ..

type Local

type Local struct {
	*rate.Limiter
}

Local ..

func (Local) Take

func (l Local) Take(ctx context.Context) time.Duration

Take ..

type Redis

type Redis struct {
	*redis_rate.Limiter
	MaxRPS int
}

Redis ..

func (Redis) Take

func (r Redis) Take(ctx context.Context) time.Duration

Take ..