ratelimit

package

v0.1.16 Latest Latest Go to latest Published: Jul 1, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var ErrLimitExceed = errors.New("rate limit exceeded")

ErrLimitExceed is returned when the rate limiter rejects a request.

This section is empty.

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

BBR implements a BBR-like adaptive limiter.

func NewLimiter(opts ...Option) *BBR

NewLimiter returns a BBR limiter.

func (l *BBR) Allow() (DoneFunc, error)

Allow checks whether a request is allowed.

func (l *BBR) Stat() Stat

Stat returns a metrics snapshot.

type DoneFunc func(DoneInfo)

DoneFunc records request completion.

type DoneInfo struct {
	Err error
}

DoneInfo contains request completion metadata.

type Limiter interface {
	Allow() (DoneFunc, error)
}

Limiter is a rate limiter.

type Option func(*options)

Option configures a BBR limiter.

func WithBucket(b int) Option

WithBucket sets the rolling window bucket count.

func WithCPUQuota(quota float64) Option

WithCPUQuota sets the real CPU quota if it differs from GOMAXPROCS.

func WithCPUThreshold(threshold int64) Option

WithCPUThreshold sets the CPU threshold, scaled from 0 to 1000.

func WithWindow(d time.Duration) Option

WithWindow sets the rolling window duration.

type Stat struct {
	CPU         int64
	InFlight    int64
	MaxInFlight int64
	MinRt       int64
	MaxPass     int64
}

Stat contains a BBR metrics snapshot.