limiter

Documentation

Index

• type Items
  • func NewItems(options ratelimit.Config, rep func(ratelimit.Config, int64)) *Items
• type Limiter
  • func GetDefaultLimiter() *Limiter
  • func New() *Limiter
  • func (c *Limiter) GetStats() (res []*proto.RateLimit)
  • func (c *Limiter) Load(id string) *Items
  • func (c *Limiter) LoadAll() (res []*Items)
  • func (c *Limiter) New(option ratelimit.Config) *Items
  • func (c *Limiter) NewOrLoad(option ratelimit.Config) *Items
  • func (c *Limiter) OnRateUpdate(id string, cb func(string, int64))
  • func (c *Limiter) Remove(option ratelimit.Config)
  • func (c *Limiter) Reporter(cfg ratelimit.Config, cur int64)
• type LimiterType

Types

type Items

type Items struct {
	Rate ratelimit.Limiter
	// contains filtered or unexported fields
}

func NewItems

func NewItems(options ratelimit.Config, rep func(ratelimit.Config, int64)) *Items

type Limiter

type Limiter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func GetDefaultLimiter

func GetDefaultLimiter() *Limiter

func New

func New() *Limiter

func (*Limiter) GetStats

func (c *Limiter) GetStats() (res []*proto.RateLimit)

func (*Limiter) Load

func (c *Limiter) Load(id string) *Items

func (*Limiter) LoadAll

func (c *Limiter) LoadAll() (res []*Items)

func (*Limiter) New

func (c *Limiter) New(option ratelimit.Config) *Items

func (*Limiter) NewOrLoad

func (c *Limiter) NewOrLoad(option ratelimit.Config) *Items

func (*Limiter) OnRateUpdate

func (c *Limiter) OnRateUpdate(id string, cb func(string, int64))

func (*Limiter) Remove

func (c *Limiter) Remove(option ratelimit.Config)

func (*Limiter) Reporter

func (c *Limiter) Reporter(cfg ratelimit.Config, cur int64)

type LimiterType

type LimiterType string

const LimiterServer LimiterType = "LimiterServer"