retry

Documentation

Index

• Constants
• type Retryer
  • func NewRetryer() *Retryer
  • func (r *Retryer) Run(ctx context.Context, fn func(context.Context) error, logF []zap.Field) error
  • func (r *Retryer) Stop()

Constants

const DefTimeout = 24 * time.Hour

DefTimeout is used as timeout for runs when the passed context has no deadline set.

Types

type Retryer

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

Retryer executes a function repeatedly until it was successful or it's context was cancelled.

func NewRetryer

func NewRetryer() *Retryer

func (*Retryer) Run

func (r *Retryer) Run(ctx context.Context, fn func(context.Context) error, logF []zap.Field) error

Run executes fn until it was successful, it returned an error that does not wrap goorderr.RetryableError or the execution was aborted via the context. If the context has no deadline set, it will be set to DefTimeout.

func (*Retryer) Stop

func (r *Retryer) Stop()

Stop notifies all Run() methods to terminate. It does not wait for their termination.