redis

Documentation

Index

• func NewFixedWindowLimiter(client *redis.Client, limit int, window time.Duration) (ratelimit.RedisLimiter, error)
• func NewLeakyBucketLimiter(client *redis.Client, peakLevel, currentVelocity int) ratelimit.RedisLimiter
• func NewSlidingLogLimiter(client *redis.Client, smallWindow time.Duration, ...) (ratelimit.RedisLimiter, error)
• func NewSlidingWindowLimiter(client *redis.Client, limit int, window, smallWindow time.Duration) (ratelimit.RedisLimiter, error)
• func NewTokenBucketLimiter(client *redis.Client, capacity, rate int) ratelimit.RedisLimiter
• type SlidingLogLimiterStrategy
  • func NewSlidingLogLimiterStrategy(limit int, window time.Duration) *SlidingLogLimiterStrategy
• type ViolationStrategyError
  • func (e *ViolationStrategyError) Error() string

Functions

func NewFixedWindowLimiter

func NewFixedWindowLimiter(client *redis.Client, limit int, window time.Duration) (ratelimit.RedisLimiter, error)

func NewLeakyBucketLimiter

func NewLeakyBucketLimiter(client *redis.Client, peakLevel, currentVelocity int) ratelimit.RedisLimiter

func NewSlidingLogLimiter

func NewSlidingLogLimiter(client *redis.Client, smallWindow time.Duration, strategies ...*SlidingLogLimiterStrategy) (
	ratelimit.RedisLimiter, error)

func NewSlidingWindowLimiter

func NewSlidingWindowLimiter(client *redis.Client, limit int, window, smallWindow time.Duration) (
	ratelimit.RedisLimiter, error)

func NewTokenBucketLimiter

func NewTokenBucketLimiter(client *redis.Client, capacity, rate int) ratelimit.RedisLimiter

Types

type SlidingLogLimiterStrategy

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

SlidingLogLimiterStrategy 滑动日志限流器的策略

func NewSlidingLogLimiterStrategy

func NewSlidingLogLimiterStrategy(limit int, window time.Duration) *SlidingLogLimiterStrategy

type ViolationStrategyError

type ViolationStrategyError struct {
	Limit  int           // 窗口请求上限
	Window time.Duration // 窗口时间大小
}

ViolationStrategyError 违背策略错误

func (*ViolationStrategyError) Error

func (e *ViolationStrategyError) Error() string