engine

Jun 15, 2026

Changes in this version

+ type Engine struct

+ func New(exec StepExecutor) *Engine

+ func NewWithRecorder(exec StepExecutor, rec Recorder) *Engine

+ func (e *Engine) Execute(ctx context.Context, comp *composition.Composition, input json.RawMessage) (json.RawMessage, error)

+ type NamedOutput struct

+ ID string

+ Output any

+ type Recorder interface

+ RecordBranch func(stepID string, takenTarget string)

+ RecordParallel func(stepID string, branches []NamedOutput)

+ RecordStepCompleted func(stepID, kind string, input, output json.RawMessage, attempt int, err error)

+ RecordStepStarted func(stepID, kind string, input json.RawMessage)

+ type Scope map[string]any

+ type StepExecutor func(ctx context.Context, step *composition.Step, input json.RawMessage) (json.RawMessage, error)