Versions in this module Expand all Collapse all v0 v0.17.0 Sep 10, 2026 Changes in this version + var ErrInvalidConfig = errors.New("coordination: invalid configuration") + var ErrInvalidProtocol = errors.New("coordination: invalid execution protocol") + var ErrInvalidState = errors.New("coordination: invalid execution state") + type Deadline struct + func NewDeadline(config DeadlineConfig) (*Deadline, error) + func (d *Deadline) Descriptor() agent.Descriptor + func (d *Deadline) Restore(state agent.ExecutionState) (agent.Execution, error) + func (d *Deadline) Start(input agent.Input) (agent.Execution, error) + type DeadlineConfig struct + Description string + Name string + type FirstSuccess struct + func NewFirstSuccess(config FirstSuccessConfig) (*FirstSuccess, error) + func (f *FirstSuccess) Descriptor() agent.Descriptor + func (f *FirstSuccess) Restore(state agent.ExecutionState) (agent.Execution, error) + func (f *FirstSuccess) Start(input agent.Input) (agent.Execution, error) + type FirstSuccessConfig struct + Accept SuccessPredicate + Description string + MaxCandidates uint32 + Name string + type FirstSuccessResult struct + Outcomes []agent.ChildOutcome + Starts []agent.ChildStartResult + Winner *agent.ChildKey + func (f FirstSuccessResult) Valid() bool + type InputGate struct + func NewInputGate(config InputGateConfig) (*InputGate, error) + func (i *InputGate) Descriptor() agent.Descriptor + func (i *InputGate) Restore(state agent.ExecutionState) (agent.Execution, error) + func (i *InputGate) Start(input agent.Input) (agent.Execution, error) + type InputGateConfig struct + AnswerSchema agent.Schema + Description string + Name string + RequestSchema agent.Schema + type SuccessPredicate func(ctx context.Context, outcome agent.ChildOutcome) (bool, error) + type Timer struct + func (Timer) Dispatch(ctx context.Context, request agent.EffectRequest, _ agent.DeltaEmitter) (agent.Settlement, error) + func (Timer) ReplayPolicy(effect agent.Effect) agent.ReplayPolicy
Go to main page