resiliency

Documentation

Index

• func IsRetryable(e error) bool
• func Retry(ctx context.Context, duration time.Duration, maxRetries int, fn RetryFunc) error
• func Retryable(e error) retryableErr
• type ErrorSet
  • func NewErrorSet(msg string, c int) *ErrorSet
  • func (e *ErrorSet) Add(errs ...error)
  • func (e *ErrorSet) Error() error
  • func (e *ErrorSet) Errors() []error
• type RetryFunc

Functions

func IsRetryable

func IsRetryable(e error) bool

IsRetryable checks if an error can be retried.

func Retry

func Retry(ctx context.Context, duration time.Duration, maxRetries int, fn RetryFunc) error

Retry retries the provided call using exponential retries given an initial duration for up to max retries count.

func Retryable

func Retryable(e error) retryableErr

Retryable returns a new instance.

Types

type ErrorSet

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

ErrorSet tracks a collection of unique errors.

func NewErrorSet

func NewErrorSet(msg string, c int) *ErrorSet

NewErrorSet returns a new instance.

func (*ErrorSet) Add

func (e *ErrorSet) Add(errs ...error)

Add adds one or more errors to the set.

func (*ErrorSet) Error

func (e *ErrorSet) Error() error

Error returns a new composite error or nil.

func (*ErrorSet) Errors

func (e *ErrorSet) Errors() []error

Error returns a list of unique errors or nil.

type RetryFunc

type RetryFunc func(ctx context.Context, retries int) (bool, error)

RetryFunc tracks resiliency retry calls.