CPSToDuration converts Calls Per Second to a duration.

NewRateLimitedQueue generates and starts up a new rate limiter.

RateLimitedConcurrent will concurrently call the transform function on the given input once per tick at the given rate.

RateLimitedSerial will call the transform function on the given input at most once per tick at the given rate.

RateLimitedWorkers will concurrently call the transform function on the given input.

SimpleParallel executes the transform function in a go routine for every input.

SimpleParallelMap executes the transform function in a go routine for every key-value pair in the input map.

Workers executes the transform function in a go routine for every input.

RateLimitedQueue can reduce the rate of incoming requests, and handle them in a timed and orderly fashion.

RateLimitedQueueConfig allows you to specify configuration when creating a new rate limiter object.