limiter

package

v1.2.4 Latest Latest Go to latest Published: Jun 1, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewLimiter(capacity int) *Limiter

NewLimiter initializes a new limiter with the specified capacity

func (l *Limiter) Capacity() int

Capacity returns the current capacity of the rate limiter

func (l *Limiter) Obtain(ctx context.Context, priority int) error

Obtain blocks until a token is available or the context is cancelled

func (l *Limiter) Release()

Release explicitly releases a token

func (l *Limiter) ReleaseAfterDelay(delay time.Duration)

ReleaseAfterDelay releases the limiter after the specified delay

func (l *Limiter) SetCapacity(newCapacity int)

SetCapacity updates the rate limiter's capacity