retrier

Documentation

Index

• func Retry(maxRetries int, backOffPeriod time.Duration, fn func() error) error
• type Retrier
  • func New(timeout time.Duration, opts ...RetrierOpt) *Retrier
  • func NewWithMaxRetries(maxRetries int, backOffPeriod time.Duration) *Retrier
  • func (r *Retrier) Retry(fn func() error) error
• type RetrierOpt
  • func WithMaxRetries(maxRetries int, backOffPeriod time.Duration) RetrierOpt
  • func WithRetryPolicy(policy RetryPolicy) RetrierOpt
• type RetryPolicy

Functions

func Retry

func Retry(maxRetries int, backOffPeriod time.Duration, fn func() error) error

Retry runs fn with a MaxRetriesPolicy

Types

type Retrier

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

func New

func New(timeout time.Duration, opts ...RetrierOpt) *Retrier

New creates a new retrier with a global timeout (max time allowed for the whole execution) The default retry policy is to always retry with no wait time in between retries

func NewWithMaxRetries

func NewWithMaxRetries(maxRetries int, backOffPeriod time.Duration) *Retrier

NewWithMaxRetries creates a new retrier with no global timeout and a max retries policy

func (*Retrier) Retry

func (r *Retrier) Retry(fn func() error) error

Retry runs the fn function until it either successful completes (not error), the set timeout reached or the retry policy aborts the execution

type RetrierOpt

type RetrierOpt func(*Retrier)

func WithMaxRetries

func WithMaxRetries(maxRetries int, backOffPeriod time.Duration) RetrierOpt

WithMaxRetries sets a retry policy that will retry up to maxRetries times with a wait time between retries of backOffPeriod

func WithRetryPolicy

func WithRetryPolicy(policy RetryPolicy) RetrierOpt

type RetryPolicy

type RetryPolicy func(totalRetries int, err error) (retry bool, wait time.Duration)

RetryPolicy allows to customize the retrying logic. The boolean retry indicates if a new retry should be performed and the wait duration indicates the wait time before the next retry