execution

Oct 8, 2026

Changes in this version

+ type Admission interface

+ Admit func(key string) (admitted bool, until time.Time)

type Attempt

+ Unadmitted bool

type Executor

+ Admission Admission

+ CredentialFailover bool

Sep 25, 2026

Changes in this version

+ func ExponentialBackoff(initial time.Duration, multiplier float64, maxDelay time.Duration) func(failed int, err error) time.Duration

+ func RepeatableRequest(request core.Request) bool

+ func Resilient(provider core.Provider, key string, policy Policy) core.Provider

+ func TransientClassification(err error) core.ProviderErrorClassification

+ type CircuitOpenError struct

+ Key string

+ RetryAfter time.Duration

+ Until time.Time

+ func (e *CircuitOpenError) Error() string

+ func (e *CircuitOpenError) ProviderErrorClassification() core.ProviderErrorClassification

+ type Policy struct

+ Classify func(error) core.ProviderErrorClassification

+ Health Health

+ Now func() time.Time

+ Repeatable func(core.Request) bool

+ Retry Retry

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

Sep 25, 2026

Changes in this version

+ const DefaultFailureThreshold

+ const DefaultOpenDuration

+ var ErrNoCandidates = errors.New("execution: no candidates")

+ type AfterOutputError struct

+ Err error

+ func (e *AfterOutputError) Error() string

+ func (e *AfterOutputError) ProviderErrorClassification() core.ProviderErrorClassification

+ func (e *AfterOutputError) Unwrap() error

+ type Attempt struct

+ Candidate C

+ Class core.ProviderErrorClass

+ Classification core.ProviderErrorClassification

+ Disposition core.Disposition

+ Duration time.Duration

+ Err error

+ Key string

+ Tries int

+ Unavailable bool

+ Until time.Time

+ type Effect int

+ const EffectFailure

+ const EffectNeutral

+ const EffectSuccess

+ type Executor struct

+ Health Health

+ Key func(C) string

+ Now func() time.Time

+ Retry Retry

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

+ type Failure struct

+ Class string

+ ClassFailures int

+ Key string

+ Streak int

+ type Health interface

+ Available func(key string) (available bool, until time.Time)

+ Record func(key string, err error)

+ type HealthOptions struct

+ Now func() time.Time

+ Observe func(error) Observation

+ Policy func(key string) HealthPolicy

+ type HealthPolicy struct

+ Backoff func(Failure) time.Duration

+ FailureThreshold int

+ FailureWindow time.Duration

+ IgnoreRetryAfter bool

+ OpenDuration time.Duration

+ type HealthState struct

+ ClassFailures map[string]int

+ CooldownUntil time.Time

+ LastFailure time.Time

+ OpenUntil time.Time

+ Streak int

+ type HealthTracker struct

+ func NewHealthTracker(options HealthOptions) *HealthTracker

+ func (t *HealthTracker) Available(key string) (bool, time.Time)

+ func (t *HealthTracker) Record(key string, err error)

+ func (t *HealthTracker) Reset(key string)

+ func (t *HealthTracker) State(key string) HealthState

+ type Observation struct

+ Class string

+ Effect Effect

+ RetryAfter time.Duration

+ func Observe(err error) Observation

+ type Result struct

+ Attempts []Attempt[C]

+ Candidate C

+ Value R

+ func ExecuteStream[C any](ctx context.Context, executor Executor[C], candidates []C, ...) (Result[C, core.StreamIter], error)

+ func Execute[C, R any](ctx context.Context, executor Executor[C], candidates []C, ...) (Result[C, R], error)

+ type Retry struct

+ Attempts int

+ Delay func(failed int, err error) time.Duration

+ type UnavailableError struct

+ RetryAfter time.Duration

+ Until time.Time

+ func (e *UnavailableError) Error() string

+ func (e *UnavailableError) ProviderErrorClassification() core.ProviderErrorClassification