ratelimit

Documentation

Index

• type Limiter
  • func NewLimiter(name string, rateLimitEvery int, rateLimitBucket int) *Limiter
  • func (l *Limiter) RequestLimitUnique(ctx context.Context) error

Types

type Limiter

type Limiter struct {
	// 限流器 名称
	Name string
	// contains filtered or unexported fields
}

Limiter 限流器结构定义

func NewLimiter

func NewLimiter(name string, rateLimitEvery int, rateLimitBucket int) *Limiter

NewLimiter 创建限流器 rateLimitEvery 每秒产生多少个令牌 rateLimitBucket 令牌桶大小

func (*Limiter) RequestLimitUnique

func (l *Limiter) RequestLimitUnique(ctx context.Context) error

RequestLimitUnique 检测是否限流 NOTE: 可传 context 上下文