retries

package
v0.0.0-...-8b3bf69 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 26, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL