ratelimit

func ChooseLimiterCapacity ¶

func ChooseLimiterCapacity(
	rateHz float64,
	window time.Duration) (capacity uint64, err error)

Choose a limiter capacity that ensures that the action gated by the limiter will be limited to within a few percent of `rateHz * window` for any window of the given size.

This is not be possible for all rates and windows. In that case, an error will be returned.

func NewThrottledBucket ¶

func NewThrottledBucket(
	opThrottle Throttle,
	egressThrottle Throttle,
	wrapped gcs.Bucket) (b gcs.Bucket)

Create a bucket that limits the rate at which it calls the wrapped bucket using opThrottle, and limits the bandwidth with which it reads from the wrapped bucket using egressThrottle.

func ThrottledReader ¶

func ThrottledReader(
	ctx context.Context,
	r io.Reader,
	throttle Throttle) io.Reader

Create a reader that limits the bandwidth of reads made from r according to the supplied throttler. Reads are assumed to be made under the supplied context.