rate

package

v1.8.2 Latest Latest Go to latest Published: Dec 10, 2025 License: GPL-3.0 Imports: 3 Imported by: 55

Details

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

This section is empty.

This section is empty.

This section is empty.

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

Limiter controls the frequency of handling events.

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

NewLimiter returns a new Limiter Pointer.

func (lim *Limiter) Acquire() bool

Acquire ...

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

AcquireN ...

func (lim *Limiter) LastTouch() int64

LastTouch ...

func (lim *Limiter) Tokens() float64

Tokens returns the left token of limiter.

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

LimiterManager ...

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

NewManager ..

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

Delete 删除对应限速器

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

Load ...