reliable

package

v0.11.0 Latest Latest Go to latest Published: Dec 28, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

View Source

const (
	MinBackoff time.Duration = 10 * time.Millisecond
	MaxBackoff time.Duration = 15 * time.Second
)

This section is empty.

func NextBackoff(d time.Duration) time.Duration

func NextBackoffCustom(d, jmin, jmax time.Duration) time.Duration

func NextDeline(d time.Duration) time.Duration

func RunGroup(ctx context.Context, fns ...RunFn) error

func Wait(ctx context.Context, d time.Duration) error

func WaitDeline(ctx context.Context, d time.Duration) error

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

func NewGroup(ctx context.Context) *Group

func (g *Group) Go(fns ...RunFn) *Group

func (g *Group) Wait() error

type RunFn func(context.Context) error

func Bind[T any](t T, fn func(context.Context, T) error) RunFn

func Schedule(d time.Duration, fn RunFn) RunFn

func ScheduleDelayed(delay, d time.Duration, fn RunFn) RunFn

func ScheduleNow(d time.Duration, fn RunFn) RunFn

type SpinBackoff struct {
	MinBackoff time.Duration
	MaxBackoff time.Duration
	// contains filtered or unexported fields
}

func (s *SpinBackoff) Wait(ctx context.Context) error

Wait will block on backoff if called too often