Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultBaseDelay = 10 * time.Second DefaultMaxDelay = 1 * time.Minute DefaultMaxTries = 3 )
Functions ¶
func NewItemExponentialFailureRateLimiterWithMaxTries ¶
func NewItemExponentialFailureRateLimiterWithMaxTries(baseDelay time.Duration, maxDelay time.Duration) ratelimiter.RateLimiter
Types ¶
type ItemExponentialFailureRateLimiterWithMaxTries ¶
type ItemExponentialFailureRateLimiterWithMaxTries struct {
// contains filtered or unexported fields
}
func (*ItemExponentialFailureRateLimiterWithMaxTries) Forget ¶
func (r *ItemExponentialFailureRateLimiterWithMaxTries) Forget(item interface{})
func (*ItemExponentialFailureRateLimiterWithMaxTries) NumRequeues ¶
func (r *ItemExponentialFailureRateLimiterWithMaxTries) NumRequeues(item interface{}) int
func (*ItemExponentialFailureRateLimiterWithMaxTries) When ¶
func (r *ItemExponentialFailureRateLimiterWithMaxTries) When(item interface{}) time.Duration
Source Files
Click to show internal directories.
Click to hide internal directories.