retrier

Documentation

Index

• func ExponentialBackoff(n int, initialAmount time.Duration) []time.Duration
• type Action
• type AdditionalTest
• type Retrier
  • func NewRetrier(n int, initial time.Duration, at AdditionalTest) *Retrier
  • func (r *Retrier) RunCtx(ctx context.Context, ...) (driver.Rows, error)

Functions

func ExponentialBackoff

func ExponentialBackoff(n int, initialAmount time.Duration) []time.Duration

Types

type Action

type Action int

const (
	Succeed         Action = iota // Succeed indicates the Retrier should treat this value as a success.
	Fail                          // Fail indicates the Retrier should treat this value as a hard failure and not retry.
	Retry                         // Retry indicates the Retrier should treat this value as a soft failure and retry.
	AdditionalCheck               // Additional check is required to determine if it's Fail or Retry
)

type AdditionalTest

type AdditionalTest interface {
	IsHardFailure(context.Context) (bool, error)
}

type Retrier

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

func NewRetrier

func NewRetrier(n int, initial time.Duration, at AdditionalTest) *Retrier

func (*Retrier) RunCtx

func (r *Retrier) RunCtx(ctx context.Context, work func(ctx context.Context) (driver.Rows, Action, error)) (driver.Rows, error)