retries

package

v0.7.0 Latest Latest Go to latest Published: Apr 5, 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 Info[T any] struct {
	Info    *T
	Timeout time.Duration
}

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

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

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

type WaitFn func() *Err