ratelimiter

type RateLimiter ¶

type RateLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

TODO consider making this also perform rate limiting with priority, so more important events take priority; also consider using or making its ICD like golang.org/x/time/rate

func New(requestsPerSecond float64) *RateLimiter

func (t *RateLimiter) Take(ctx context.Context) error

func (t *RateLimiter) TakeMore(ctx context.Context, rateBlocksBefore, rateBlocksAfter int) error

func (rl *RateLimiter) TimePerRequests() time.Duration