ratelimit

package

v0.1.1 Latest Latest Go to latest Published: Nov 6, 2025 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Limiter implements a simple token bucket rate limiter backed by KVS

func NewLimiter(rate int, interval time.Duration, kvsStore kvs.Store) *Limiter

NewLimiter creates a new rate limiter backed by KVS rate: number of allowed requests interval: time window for the rate

func (l *Limiter) Allow(key string) bool

Allow checks if a request is allowed for the given key

func (l *Limiter) Cleanup(maxAge time.Duration)

Cleanup removes old buckets that haven't been used recently

func (l *Limiter) Reset(key string)

Reset clears the rate limit for a specific key