retries

package

v0.28.1 Latest Latest Go to latest Published: Dec 19, 2023 License: Apache-2.0 Imports: 6 Imported by: 4

Details

This section is empty.

This section is empty.

func Backoff(attempt int) time.Duration

func Poll[T any](pctx context.Context, timeout time.Duration, fn func() (*T, *Err)) (*T, error)

func Wait(pctx context.Context, timeout time.Duration, fn WaitFn) error

type Err struct {
	Err  error
	Halt bool
}

func Continue(err error) *Err

func Continuef(format string, err error, args ...interface{}) *Err

func Continues(msg string) *Err

func Halt(err error) *Err

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

func (et *ErrTimedOut) Error() string

func (et *ErrTimedOut) Unwrap() error

type Info[T any] struct {
	Info    *T
	Timeout time.Duration
}

Deprecated: use return types from non-*AndWait methods

type Option[T any] func(*Info[T])

Deprecated: use return types from non-*AndWait methods

func OnPoll[T any](callback func(*T)) Option[T]

Deprecated: use return types from non-*AndWait methods

func Timeout[T any](dur time.Duration) Option[T]

Deprecated: use return types from non-*AndWait methods

type WaitFn func() *Err