ratelimit

Mar 18, 2024

Changes in this version

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

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

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

+ type Throttle interface

+ Capacity func() (c uint64)

+ Wait func(ctx context.Context, tokens uint64) (err error)

+ func NewThrottle(rateHz float64, capacity uint64) (t Throttle)