retries

Documentation

Index

• type Retries
  • func New() *Retries
  • func NewFromGRPC(grpcBackoff *backoff.Config) *Retries
  • func (r *Retries) Clone() *Retries
  • func (r *Retries) Duration(attempt int) time.Duration
  • func (r *Retries) Max() time.Duration
  • func (r *Retries) Retry(ctx context.Context, op func(int) error) error
  • func (r *Retries) RetryIf(ctx context.Context, op func(int) error, ...) error
  • func (r *Retries) Wait(ctx context.Context) error

Types

type Retries

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

func New

func New() *Retries

TODO: make it configurable

func NewFromGRPC

func NewFromGRPC(grpcBackoff *backoff.Config) *Retries

func (*Retries) Clone

func (r *Retries) Clone() *Retries

func (*Retries) Duration

func (r *Retries) Duration(attempt int) time.Duration

func (*Retries) Max

func (r *Retries) Max() time.Duration

func (*Retries) Retry

func (r *Retries) Retry(ctx context.Context, op func(int) error) error

func (*Retries) RetryIf

func (r *Retries) RetryIf(
	ctx context.Context,
	op func(int) error,
	isRecoverableError func(err error) bool,
) error

func (*Retries) Wait

func (r *Retries) Wait(ctx context.Context) error