throttle

Documentation

Index

• type MemoryRateLimiter
  • func NewMemoryRateLimiter(qps int) *MemoryRateLimiter
  • func (rl *MemoryRateLimiter) Acquire()
  • func (rl *MemoryRateLimiter) String() string
  • func (rl *MemoryRateLimiter) TryAcquire() bool
• type RateLimiter
• type RedisRateLimiter
  • func NewRedisRateLimiter(client *redis.RedisClient, luaPath string, qps int, serviceId string) (*RedisRateLimiter, error)
  • func (rrl *RedisRateLimiter) Acquire()
  • func (rrl *RedisRateLimiter) TryAcquire() bool

Types

type MemoryRateLimiter

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

基于内存存储的限速器

func NewMemoryRateLimiter

func NewMemoryRateLimiter(qps int) *MemoryRateLimiter

创建限速器 qps: 每秒最大请求数

func (*MemoryRateLimiter) Acquire

func (rl *MemoryRateLimiter) Acquire()

获取token, 如果没有则block

func (*MemoryRateLimiter) String

func (rl *MemoryRateLimiter) String() string

func (*MemoryRateLimiter) TryAcquire

func (rl *MemoryRateLimiter) TryAcquire() bool

获取token, 成功返回true, 没有则返回false

type RateLimiter

type RateLimiter interface {
	Acquire()
	TryAcquire() bool
}

type RedisRateLimiter

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

func NewRedisRateLimiter

func NewRedisRateLimiter(client *redis.RedisClient, luaPath string, qps int, serviceId string) (*RedisRateLimiter, error)

func (*RedisRateLimiter) Acquire

func (rrl *RedisRateLimiter) Acquire()

func (*RedisRateLimiter) TryAcquire

func (rrl *RedisRateLimiter) TryAcquire() bool