retry

Documentation

Index

• Variables
• func OnError(ctx context.Context, retriable RetriableFn, fn func(ctx context.Context) error, ...) error
• type RetriableFn
• type RetryOption
  • func WithLogger(logger logr.Logger) RetryOption
  • func WithRetryIntervalSec(intervalSec int) RetryOption
  • func WithRetryTimoutSec(timeoutSec int) RetryOption
• type RetryOptions

Variables

var (
	ErrTimeout = errors.New("timed out waiting for the function to complete")
)

Functions

func OnError

func OnError(ctx context.Context, retriable RetriableFn, fn func(ctx context.Context) error, opts ...RetryOption) error

Types

type RetriableFn

type RetriableFn func(error) bool

type RetryOption

type RetryOption func(*RetryOptions)

func WithLogger

func WithLogger(logger logr.Logger) RetryOption

func WithRetryIntervalSec

func WithRetryIntervalSec(intervalSec int) RetryOption

func WithRetryTimoutSec

func WithRetryTimoutSec(timeoutSec int) RetryOption

type RetryOptions

type RetryOptions struct {
	Interval time.Duration
	Timeout  time.Duration
	Logger   logr.Logger
}