execution

package

Go to main page

Versions in this module

v1

v1.2.1

Sep 11, 2026

v1.2.0

Sep 2, 2026

v1.1.0

Aug 30, 2026

Changes in this version

+ type Attempt func(context.Context, routing.Attempt) (*Response, *failure.Failure, AttemptAction)

type AttemptEvidence

+ Credential CredentialEvidence

type CredentialEvidence

+ Source string

type CredentialOwner

+ const CredentialOwnerAccount

+ type OverheadTimer struct

+ func OverheadTimerFrom(ctx context.Context) *OverheadTimer

+ func WithOverheadTimer(ctx context.Context) (context.Context, *OverheadTimer)

+ func (t *OverheadTimer) OverheadMS() int64

+ func (t *OverheadTimer) TrackUpstream() func()

+ type Result struct

+ Attempts []AttemptEvidence

+ FinishedAt time.Time

+ Response Response

+ Route routing.Route

+ StartedAt time.Time

+ func Execute[Response any](ctx context.Context, executor *Executor, plan *routing.Plan, ...) (*Result[Response], error)

v1.0.5

Aug 20, 2026

v1.0.4

Aug 13, 2026

v1.0.3

Aug 11, 2026

Changes in this version

+ func RecordCredential(ctx context.Context, evidence CredentialEvidence)

+ func RecordCredentialAccepted(ctx context.Context)

+ type AttemptOutcome struct

+ Credential CredentialEvidence

+ Failure *failure.Failure

+ Route routing.Route

+ type CredentialEvidence struct

+ Accepted bool

+ MaterialVersion string

+ Owner CredentialOwner

+ type CredentialOwner string

+ const CredentialOwnerOperator

+ const CredentialOwnerTenant

+ type OutcomePublisher interface

+ PublishOutcome func(AttemptOutcome)

v1.0.2

Aug 11, 2026

Changes in this version

+ func WithAttemptAction(err error, action AttemptAction) error

+ type AttemptAction uint8

+ const AttemptActionContinueRoute

+ const AttemptActionDefault

+ const AttemptActionFallbackRoute

+ const AttemptActionStop

type Availability

+ Release func(routing.Route)

+ type EmbeddingAttempt func(context.Context, routing.Attempt) (*inference.EmbeddingResponse, *failure.Failure, AttemptAction)

+ type EmbeddingResult struct

+ Attempts []AttemptEvidence

+ FinishedAt time.Time

+ Response inference.EmbeddingResponse

+ Route routing.Route

+ StartedAt time.Time

type Executor

+ func (e *Executor) ExecuteEmbedding(ctx context.Context, plan *routing.Plan, attempt EmbeddingAttempt) (*EmbeddingResult, error)

v1.0.1

Aug 10, 2026

v1.0.0

Aug 9, 2026

Changes in this version

+ var ErrAllAttemptsFailed = errors.New("all planned attempts failed")

+ var ErrAttemptBudget = errors.New("logical attempt budget exhausted")

+ var ErrAttemptRequired = errors.New("provider attempt function is required")

+ var ErrElapsedBudget = errors.New("execution elapsed-time budget exhausted")

+ var ErrPlanRequired = errors.New("route plan is required")

+ func CanFallback(providerFailure *failure.Failure) bool

+ func IsStreamTerminal(err error) bool

+ type AttemptEvidence struct

+ Duration time.Duration

+ Failure *failure.Failure

+ FinishedAt time.Time

+ Number int

+ Retry int

+ Route routing.Route

+ StartedAt time.Time

+ State State

+ Transitions []Transition

+ type Availability interface

+ Acquire func(routing.Route) bool

+ RecordFailure func(routing.Route, *failure.Failure, time.Duration)

+ RecordSuccess func(routing.Route, time.Duration)

+ type ChatAttempt func(context.Context, routing.Attempt) (*inference.ChatResponse, *failure.Failure)

+ type ChatResult struct

+ Attempts []AttemptEvidence

+ FinishedAt time.Time

+ Response inference.ChatResponse

+ Route routing.Route

+ StartedAt time.Time

+ type Clock interface

+ Now func() time.Time

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

+ type Config struct

+ BackoffMultiplier float64

+ MaxAttempts int

+ MaxBackoff time.Duration

+ MaxElapsed time.Duration

+ MaxRetriesPerRoute int

+ RetryBackoff time.Duration

+ func DefaultConfig() Config

+ type Error struct

+ Attempts []AttemptEvidence

+ Failure *failure.Failure

+ Reason error

+ func (e *Error) Error() string

+ func (e *Error) Is(target error) bool

+ func (e *Error) Unwrap() error

+ type Executor struct

+ func New(config Config, clock Clock, availability Availability) (*Executor, error)

+ func (e *Executor) ExecuteChat(ctx context.Context, plan *routing.Plan, attempt ChatAttempt) (*ChatResult, error)

+ func (e *Executor) StartChatStream(ctx context.Context, plan *routing.Plan, attempt StreamAttempt) (ManagedStream, error)

+ type ManagedStream interface

+ Attempts func() []AttemptEvidence

+ Committed func() bool

+ ModelUsed func() string

+ type State string

+ const StateCanceled

+ const StateFailed

+ const StateQueued

+ const StateRunning

+ const StateSkipped

+ const StateSucceeded

+ type Stream interface

+ Close func() error

+ Read func() (*inference.StreamEvent, error)

+ type StreamAttempt func(context.Context, routing.Attempt) (Stream, *failure.Failure)

+ type Transition struct

+ At time.Time

+ From State

+ To State

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL