sdk

Documentation

Index

• func NeverAbort() error
• func RetryForError(api func() error, retries int, abort func() error, sleep time.Duration, ...) (err error)
• func SleepForRetry(sleep, after time.Duration, abort func() error) (err error)
• type NetError
  • func NewNetError(err error, retryAfter ...time.Duration) *NetError
  • func (ne *NetError) Error() string
  • func (ne *NetError) GetRetryAfter() time.Duration
  • func (ne *NetError) Unwrap() error
• type Retryable

Functions

func NeverAbort

func NeverAbort() error

func RetryForError

func RetryForError(api func() error, retries int, abort func() error, sleep time.Duration, logger log.Logger) (err error)

RetryForError loop max `retries` count to call api(). returns the error if api() returns a non Retryable error. returns the error if abort() returns error. call SleepForRetry(sleep, after, abort), if api() returns a Retryable error.

func SleepForRetry

func SleepForRetry(sleep, after time.Duration, abort func() error) (err error)

SleepForRetry loop to sleep(`sleep`) until 'after' duration elapsed. call 'abort()' every 'sleep' interval, if abort() returns error, returns it. if 'sleep' <= 0, 'sleep' = time.Second. if 'sleep' > 'after', 'sleep' = 'after'.

Types

type NetError

type NetError struct {
	Err        error
	RetryAfter time.Duration
}

func NewNetError

func NewNetError(err error, retryAfter ...time.Duration) *NetError

func (*NetError) Error

func (ne *NetError) Error() string

func (*NetError) GetRetryAfter

func (ne *NetError) GetRetryAfter() time.Duration

func (*NetError) Unwrap

func (ne *NetError) Unwrap() error

type Retryable

type Retryable interface {
	GetRetryAfter() time.Duration
}