repeater

Documentation

Overview

Package repeater calls a function until it returns no error, up to some number of iterations and delays defined by strategy

Index

• type ExponentialBackoff
  • func (s ExponentialBackoff) Start(ctx context.Context) <-chan struct{}
• type Repeater
  • func New(strategy Strategy) *Repeater
  • func (r Repeater) Do(ctx context.Context, fn func(context.Context) error) error
• type Strategy
  • func DefaultExponentialBackoff() Strategy
  • func FixedDelay(repeats int, delay time.Duration) Strategy
  • func Once() Strategy

Types

type ExponentialBackoff

type ExponentialBackoff struct {
	InitialInterval     time.Duration
	MaxElapsedTime      time.Duration
	Multiplier          float64
	RandomizationFactor float64
}

func (ExponentialBackoff) Start

func (s ExponentialBackoff) Start(ctx context.Context) <-chan struct{}

type Repeater

type Repeater struct {
	Strategy
}

func New

func New(strategy Strategy) *Repeater

func (Repeater) Do

func (r Repeater) Do(ctx context.Context, fn func(context.Context) error) error

type Strategy

type Strategy interface {
	Start(context.Context) <-chan struct{}
}

func DefaultExponentialBackoff

func DefaultExponentialBackoff() Strategy

func FixedDelay

func FixedDelay(repeats int, delay time.Duration) Strategy

func Once

func Once() Strategy