limiter

Documentation

Index

• func Per(eventCount int, duration time.Duration) rate.Limit
• type MultiLimiter
  • func NewMultiLimiter(limiters ...RateLimiter) *MultiLimiter
  • func (ml *MultiLimiter) Limit() rate.Limit
  • func (ml *MultiLimiter) Wait(ctx context.Context) error
• type RateLimiter

Functions

func Per

func Per(eventCount int, duration time.Duration) rate.Limit

Per calculates the rate of the limiter according to eventCount and duration

Types

type MultiLimiter

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

func NewMultiLimiter

func NewMultiLimiter(limiters ...RateLimiter) *MultiLimiter

func (*MultiLimiter) Limit

func (ml *MultiLimiter) Limit() rate.Limit

func (*MultiLimiter) Wait

func (ml *MultiLimiter) Wait(ctx context.Context) error

type RateLimiter

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