rate

Documentation

Overview

Package rate provides a rate limiter hooker, this package is based on golang.org/x/time/rate

Index

• type Limiter
  • func NewLimiter(interval time.Duration, burst int) *Limiter
  • func (lim *Limiter) Acquire() bool
  • func (lim *Limiter) AcquireN(n int) bool
  • func (lim *Limiter) LastTouch() int64
  • func (lim *Limiter) Tokens() float64
• type LimiterManager
  • func NewManager[K comparable](interval time.Duration, burst int) *LimiterManager[K]
  • func (l *LimiterManager[K]) Delete(key K)
  • func (l *LimiterManager[K]) Load(key K) *Limiter

Types

type Limiter

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

Limiter controls the frequency of handling events.

func NewLimiter

func NewLimiter(interval time.Duration, burst int) *Limiter

NewLimiter returns a new Limiter Pointer.

func (*Limiter) Acquire

func (lim *Limiter) Acquire() bool

Acquire ...

func (*Limiter) AcquireN

func (lim *Limiter) AcquireN(n int) bool

AcquireN ...

func (*Limiter) LastTouch

func (lim *Limiter) LastTouch() int64

LastTouch ...

func (*Limiter) Tokens

func (lim *Limiter) Tokens() float64

Tokens returns the left token of limiter.

type LimiterManager

type LimiterManager[K comparable] struct {
	// contains filtered or unexported fields
}

LimiterManager ...

func NewManager

func NewManager[K comparable](interval time.Duration, burst int) *LimiterManager[K]

NewManager ..

func (*LimiterManager[K]) Delete

func (l *LimiterManager[K]) Delete(key K)

Delete 删除对应限速器

func (*LimiterManager[K]) Load

func (l *LimiterManager[K]) Load(key K) *Limiter

Load ...