ratelimit

Documentation

Index

• func ParseRate(rate string) (count int, interval time.Duration, err error)
• type Limiter
  • func NewLimiter(maxCount int, interval time.Duration) *Limiter
  • func (l *Limiter) Acquire(ctx context.Context) error

Functions

func ParseRate

func ParseRate(rate string) (count int, interval time.Duration, err error)

ParseRate parses rate in form of "N/D", e.g "10/1s" or "100/1ms"

Types

type Limiter

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

Limiter is precise rate limiter with context support.

func NewLimiter

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

NewLimiter returns limiter that throttles rate of successful Acquire() calls to maxSize events at any given interval.

func (*Limiter) Acquire

func (l *Limiter) Acquire(ctx context.Context) error