limiter

Documentation

Index

• type LimiterIFS
  • func NewLimiter(ops ...Option) (lifs LimiterIFS)
• type Option
  • func WithLimit(limit int) Option
  • func WithNamespace(namespace string) Option
  • func WithRedis(redisClient myredis.RedisDial) Option
  • func WithTsTimeout(isTsTimeout bool) Option

Types

type LimiterIFS

type LimiterIFS interface {
	Acquire(timeout int) (string, error)                 // 获取一个
	Release(token string)                                // 释放
	GetTimeDuration(token string) (time.Duration, error) // 获取超时时间

	Init() // 重新初始化
}

func NewLimiter

func NewLimiter(ops ...Option) (lifs LimiterIFS)

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithLimit

func WithLimit(limit int) Option

WithLimit 设置最大并发数

func WithNamespace

func WithNamespace(namespace string) Option

WithNamespace 设置命名空间

func WithRedis

func WithRedis(redisClient myredis.RedisDial) Option

WithRedis 设置默认redis

func WithTsTimeout

func WithTsTimeout(isTsTimeout bool) Option

WithRedis 是否超时记录