ratelimit

Documentation

Index

• type RateLimiter
  • func NewRateLimiter(ctx context.Context, interval time.Duration, numEvents int, ...) *RateLimiter
  • func (r *RateLimiter) Drop()

Types

type RateLimiter

type RateLimiter struct {
	*rate.Limiter
	// contains filtered or unexported fields
}

func NewRateLimiter

func NewRateLimiter(ctx context.Context, interval time.Duration, numEvents int, encoder encoder.EventEncoder) *RateLimiter

func (*RateLimiter) Drop

func (r *RateLimiter) Drop()