retry

Documentation

Index

• Variables
• type BreakPredicate
  • func IsErr(err error) BreakPredicate
• type Loop
  • func NewLoop(name string, attemptsQuantity int, wait time.Duration) *Loop
  • func NewSilentLoop(name string, attemptsQuantity int, wait time.Duration) *Loop
  • func (l *Loop) BreakIf(pred BreakPredicate) *Loop
  • func (l *Loop) Run(task func() error) error
  • func (l *Loop) RunContext(ctx context.Context, task func() error) error
  • func (l *Loop) WithInterruptable(flag bool) *Loop
  • func (l *Loop) WithLogger(logger log.Logger) *Loop
  • func (l *Loop) WithShowError(flag bool) *Loop

Variables

var InTestEnvironment = false

Types

type BreakPredicate

type BreakPredicate func(err error) bool

func IsErr

func IsErr(err error) BreakPredicate

type Loop

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

Loop retries a task function until it succeeded with number of attempts and delay between runs are adjustable.

func NewLoop

func NewLoop(name string, attemptsQuantity int, wait time.Duration) *Loop

NewLoop create Loop with features: - it is "verbose" loop — it prints messages through logboek. - this loop is interruptable by the signal watcher in tomb package.

func NewSilentLoop

func NewSilentLoop(name string, attemptsQuantity int, wait time.Duration) *Loop

NewSilentLoop create Loop with features: - it is "silent" loop — no messages are printed through logboek. - this loop is not interruptable by the signal watcher in tomb package.

func (*Loop) BreakIf

func (l *Loop) BreakIf(pred BreakPredicate) *Loop

func (*Loop) Run

func (l *Loop) Run(task func() error) error

func (*Loop) RunContext

func (l *Loop) RunContext(ctx context.Context, task func() error) error

RunContext retries a task like Run but breaks if context done.

func (*Loop) WithInterruptable

func (l *Loop) WithInterruptable(flag bool) *Loop

func (*Loop) WithLogger

func (l *Loop) WithLogger(logger log.Logger) *Loop

func (*Loop) WithShowError

func (l *Loop) WithShowError(flag bool) *Loop