retrystrategies

Documentation

Index

• type DefaultRetryStrategy
  • func NewDefault(intervalSeconds uint64) *DefaultRetryStrategy
  • func (r *DefaultRetryStrategy) NextDuration(attempts uint64) time.Duration
• type ExponentialBackoffRetryStrategy
  • func NewExponential(millis []uint) *ExponentialBackoffRetryStrategy
  • func NewExponentialWithJitter(millis []uint, customJitter JitterFn) *ExponentialBackoffRetryStrategy
  • func (r *ExponentialBackoffRetryStrategy) NextDuration(attempts uint64) time.Duration
• type JitterFn
• type RetryStrategy
  • func NewRetryStrategyFromMetadata(m datastore.Metadata) RetryStrategy

Types

type DefaultRetryStrategy

type DefaultRetryStrategy struct {
	// contains filtered or unexported fields
}

func NewDefault

func NewDefault(intervalSeconds uint64) *DefaultRetryStrategy

func (*DefaultRetryStrategy) NextDuration

func (r *DefaultRetryStrategy) NextDuration(attempts uint64) time.Duration

type ExponentialBackoffRetryStrategy

type ExponentialBackoffRetryStrategy struct {
	// contains filtered or unexported fields
}

based off https://blog.gopheracademy.com/advent-2014/backoff/

func NewExponential

func NewExponential(millis []uint) *ExponentialBackoffRetryStrategy

func NewExponentialWithJitter

func NewExponentialWithJitter(millis []uint, customJitter JitterFn) *ExponentialBackoffRetryStrategy

func (*ExponentialBackoffRetryStrategy) NextDuration

func (r *ExponentialBackoffRetryStrategy) NextDuration(attempts uint64) time.Duration

type JitterFn

type JitterFn func(uint) int

type RetryStrategy

type RetryStrategy interface {
	// NextDuration is how long we should wait before next retry
	NextDuration(attempts uint64) time.Duration
}

func NewRetryStrategyFromMetadata

func NewRetryStrategyFromMetadata(m datastore.Metadata) RetryStrategy