retry

package

v0.26.2 Latest Latest Go to latest Published: Jun 1, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var BudgetExceeded = errors.New("retry: budget exceeded")

func Do(cfg Config, fn func() error) error

func DoBudget(b Budget, cfg Config, fn func() error) error

func DoCtx(h ctxpkg.Handle, cfg Config, fn func(ctxpkg.Handle) error) error

func Open(b Budget) bool

func Sleep(cfg Config, attempt int)

type Budget struct {
	Key         string
	MaxFailures int
	Window      time.Duration
	// contains filtered or unexported fields
}

func NewBudget() Budget

func WithKey(b Budget, key string) Budget

func WithLimit(b Budget, maxFailures int, window time.Duration) Budget

type Config struct {
	MaxAttempts  int
	InitialDelay int
	Strategy     Strategy
}

func Attempts(cfg Config, maxAttempts int) Config

func Delay(cfg Config, delayMs int) Config

func Exponential(cfg Config) Config

func Linear(cfg Config) Config

func New() Config

type Strategy string

const (
	StrategyLinear      Strategy = "linear"
	StrategyExponential Strategy = "exponential"
)

func ParseStrategy(s string) (Strategy, bool)

func (e Strategy) String() string