package
1.3.0
Repository: https://github.com/warpstreamlabs/bento.git
Documentation: pkg.go.dev

# Functions

New creates a new throttle, which permits a static number of consecutive retries before throttling subsequent retries.
OptCloseChan sets a read-only channel that, if closed, will interrupt a retry throttle early.
OptMaxExponentPeriod sets the maximum period of time that throttles will last when exponentially increasing.
OptMaxUnthrottledRetries sets the maximum number of consecutive retries that will be attempted before throttling will begin.
OptThrottlePeriod sets the static period of time that throttles will last.

# Structs

Type is a throttle of retries to avoid endless busy loops when a message fails to reach its destination.