retry

type BackoffProvider ¶

type BackoffProvider interface {
	BackoffByAttempt(attempts int) (time.Duration, error)
}

type ExponentialJitterBackoff ¶

type ExponentialJitterBackoff struct {
	Base        time.Duration // Base backoff duration
	Cap         time.Duration // The maximum backoff time generated
	MaxAttempts int           // If set will throw ErrBackoffExhausted if reached

	JitterSource io.Reader //
}

ExponentialJitterBackoff provides an exponentially growing backoff duration with jitter to discourage the thundering herd problem.

BackoffByAttempt will return `random_between(0, min(cap, base * 2 ** attempts))`

This is the "Full Jitter" algorithm described at https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/

func (provider *ExponentialJitterBackoff) BackoffByAttempt(attempts int) (time.Duration, error)