bucket

Documentation

Index

• type Iface
• type Limier
• type PrefixLimiter
  • func NewPrefixLimiter() *PrefixLimiter
  • func (p *PrefixLimiter) AddBuckets(rules ...Rule) Iface
  • func (p *PrefixLimiter) GetBucket(key string) (*ratelimit.Bucket, bool)
  • func (p *PrefixLimiter) Key(c *gin.Context) string
• type PrefixTree
  • func NewPrefixTree() *PrefixTree
  • func (t *PrefixTree) Get(prefix []string) interface{}
  • func (t *PrefixTree) Put(prefix []string, v interface{})
• type Rule

Types

type Iface

type Iface interface {
	Key(c *gin.Context) string                      // 获取对应的限流器的键值对名称。
	GetBucket(key string) (*ratelimit.Bucket, bool) // 获取对应的限流器的键值对名称。
	AddBuckets(rules ...Rule) Iface                 // 新增多个令牌桶规则。
}

type Limier

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

Limier 存储令牌桶与键值对名称的映射关系

type PrefixLimiter

type PrefixLimiter struct {
	*Limier
	*PrefixTree
}

func NewPrefixLimiter

func NewPrefixLimiter() *PrefixLimiter

func (*PrefixLimiter) AddBuckets

func (p *PrefixLimiter) AddBuckets(rules ...Rule) Iface

func (*PrefixLimiter) GetBucket

func (p *PrefixLimiter) GetBucket(key string) (*ratelimit.Bucket, bool)

func (*PrefixLimiter) Key

func (p *PrefixLimiter) Key(c *gin.Context) string

type PrefixTree

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

func NewPrefixTree

func NewPrefixTree() *PrefixTree

func (*PrefixTree) Get

func (t *PrefixTree) Get(prefix []string) interface{}

func (*PrefixTree) Put

func (t *PrefixTree) Put(prefix []string, v interface{})

type Rule

type Rule struct {
	Key          string        // 自定义键值对名称
	FillInterval time.Duration // 增加新桶的间隔时间
	Cap          int64         // 桶的最大容量
	Quantum      int64         // 每次到达间隔时间之后存放的桶数量
}