workflow

package

Go to main page

Versions in this module

v0

v0.61.0

Nov 10, 2026

v0.60.0

Nov 4, 2026

Changes in this version

+ func Adapt[I, A, B, O any](compiler *run.Compiler, config AdaptConfig, child run.Program[A, B], ...) (run.Program[I, O], error)

+ type AdaptConfig struct

+ Budget run.Budget

+ Capabilities run.CapabilitySet

+ Configuration any

+ Description string

+ Name string

+ Revision string

type CallConfig

+ Child run.ChildBinding

type Config

+ Configuration any

+ Revision string

type ForkBranch

+ Child run.ChildBinding

type MapConfig

+ Child run.ChildBinding

type SwitchCase

+ Child run.ChildBinding

type Topology

+ func TopologyOf[I, O any](program run.Program[I, O]) (Topology, error)

v0.59.0

Nov 1, 2026

Changes in this version

+ func Compile[I, O any](ctx context.Context, cfg Config) (run.Program[I, O], error)

type BindingRole

+ func (b BindingRole) String() string

+ func (b BindingRole) Valid() bool

type BindingTopology

+ ProgramRef run.ProgramRef

+ type Config struct

+ BuildIdentity run.Digest

+ CallbackIdentity run.Digest

+ Description string

+ Name string

+ Stages []Stage

type Definition

+ func (d *Definition) ChildDeployments() []run.Program[run.Payload, run.Payload]

type StageKind

+ func (s StageKind) String() string

+ func (s StageKind) Valid() bool

v0.17.0

Sep 10, 2026

v0.16.0

Sep 9, 2026

v0.15.0

Sep 7, 2026

v0.14.0

Sep 1, 2026

v0.13.0

Aug 31, 2026

Changes in this version

type MapConfig

+ MaxItems uint32

type StageTopology

+ MaxItems uint32

v0.12.0

Aug 30, 2026

v0.11.0

Aug 30, 2026

v0.10.0

Aug 30, 2026

v0.2.1

Aug 30, 2026

Changes in this version

+ var ErrInvalidDefinitionConfig = errors.New("workflow: invalid definition configuration")

+ var ErrInvalidExecutionState = errors.New("workflow: invalid execution state")

+ var ErrInvalidProtocol = errors.New("workflow: invalid protocol payload")

+ var ErrInvalidStage = errors.New("workflow: invalid stage")

+ type BindingRole string

+ const BindingRoleBody

+ const BindingRoleBranch

+ const BindingRoleCall

+ const BindingRoleCase

+ const BindingRoleInvalid

+ const BindingRoleItem

+ type BindingTopology struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ DeploymentRef agent.DeploymentRef

+ ID string

+ InputSchema agent.Schema

+ OutputSchema agent.Schema

+ Role BindingRole

+ type CallConfig struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ Deployment agent.Deployment

+ ID string

+ type Definition struct

+ func NewDefinition(config DefinitionConfig) (*Definition, error)

+ func (d *Definition) Descriptor() agent.Descriptor

+ func (d *Definition) Restore(state agent.ExecutionState) (agent.Execution, error)

+ func (d *Definition) Start(input agent.Input) (agent.Execution, error)

+ func (d *Definition) Topology() Topology

+ type DefinitionConfig struct

+ Description string

+ Name string

+ Stages []Stage

+ type Dispatcher struct

+ func (Dispatcher) Dispatch(ctx context.Context, request agent.EffectRequest, emit agent.DeltaEmitter) (agent.Settlement, error)

+ func (Dispatcher) ReplayPolicy(effect agent.Effect) agent.ReplayPolicy

+ type ForkBranch struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ Deployment agent.Deployment

+ ID string

+ type ForkConfig struct

+ Branches []ForkBranch

+ ID string

+ Reduce ForkReducer[B, O]

+ WindowSize uint32

+ type ForkReducer func(branchOutputs []B) (O, error)

+ type LoopConfig struct

+ Body agent.Deployment

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ ID string

+ MaxIterations uint32

+ Predicate LoopPredicate[T]

+ type LoopPredicate func(value T) (bool, error)

+ type LoopResult struct

+ Iterations uint32

+ Satisfied bool

+ Value T

+ func (l LoopResult[T]) Valid() bool

+ type MapConfig struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ Deployment agent.Deployment

+ ID string

+ ItemLimit uint32

+ WindowSize uint32

+ type Stage struct

+ func Call(config CallConfig) (Stage, error)

+ func Fork[I, B, O any](config ForkConfig[I, B, O]) (Stage, error)

+ func Loop[T any](config LoopConfig[T]) (Stage, error)

+ func Map[I, O any](config MapConfig[I, O]) (Stage, error)

+ func Switch[I any](config SwitchConfig[I]) (Stage, error)

+ func Transform[I, O any](id string, transform TransformFunc[I, O]) (Stage, error)

+ func (s Stage) Valid() bool

+ type StageKind string

+ const StageKindCall

+ const StageKindFork

+ const StageKindInvalid

+ const StageKindLoop

+ const StageKindMap

+ const StageKindSwitch

+ const StageKindTransform

+ type StageTopology struct

+ Bindings []BindingTopology

+ ID string

+ InputSchema agent.Schema

+ ItemLimit uint32

+ Kind StageKind

+ MaxIterations uint32

+ OutputSchema agent.Schema

+ WindowSize uint32

+ type SwitchCase struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ Deployment agent.Deployment

+ ID string

+ type SwitchConfig struct

+ Cases []SwitchCase

+ ID string

+ Select SwitchSelector[I]

+ type SwitchSelector func(input I) (caseID string, err error)

+ type Topology struct

+ Descriptor agent.Descriptor

+ Stages []StageTopology

+ type TransformFunc func(input I) (O, error)

v0.2.0

Aug 27, 2026

v0.1.0

Aug 27, 2026

v0.0.1

Aug 27, 2026

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