rate

Documentation

Index

• type Limit
• type LimitFactory
• type Limiter
  • func NewRateLimiter(freq time.Duration, burstSize int) *Limiter
  • func (c *Limiter) Create() Limit

Types

type Limit

type Limit interface {
	Wait(ctx context.Context) (err error)
}

Limit is partially representing standard lib's rate limiter

type LimitFactory

type LimitFactory interface {
	Create() Limit
}

LimitFactory is an interface for creating per-connection rate limiters

type Limiter

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

Limiter is wrapper around golang's rate.Limit for more balanced rate limiting among multiple connections

func NewRateLimiter

func NewRateLimiter(freq time.Duration, burstSize int) *Limiter

NewRateLimiter returns a new Limiter

func (*Limiter) Create

func (c *Limiter) Create() Limit

Create returns a new standard lib's rate limiter for each connectin with a given frequency and burstSize