engine

package

Go to main page

Versions in this module

v0

v0.8.12

Sep 4, 2026

v0.8.11

Sep 4, 2026

v0.8.10

Sep 4, 2026

v0.8.9

Sep 3, 2026

v0.8.8

Sep 3, 2026

v0.8.7

Aug 17, 2026

v0.8.6

Aug 16, 2026

v0.8.5

Aug 16, 2026

v0.8.4

Aug 16, 2026

v0.8.3

Aug 16, 2026

v0.8.2

Aug 16, 2026

v0.8.1

Aug 15, 2026

v0.8.0

Aug 13, 2026

Changes in this version

type NodeCompletedData

+ Usage *agent.MetricSet

v0.7.0

Jul 23, 2026

v0.6.0

Jul 21, 2026

Changes in this version

+ type RetryNotice struct

+ Attempts int

+ Cause error

+ Delay time.Duration

+ FailedAttempt int

+ NextAttempt int

+ Outcome Outcome

+ Path string

type RunOptions

+ OnRetry func(RetryNotice)

+ type RunWithRetryOption func(*runWithRetryOptions)

+ func WithRetryNotice(observer func(RetryNotice)) RunWithRetryOption

v0.5.2

Jul 15, 2026

v0.5.1

Jul 8, 2026

v0.5.0

Jul 8, 2026

v0.4.1

Jul 7, 2026

v0.4.0

Jul 7, 2026

Changes in this version

type ResolvedInputs

+ RoleWith ir.RawConfig

v0.3.0

Jul 7, 2026

Changes in this version

+ func BareRunHandleKey(nodePath string) string

type LocalDispatcher

+ func (d *LocalDispatcher) WithRawHandle(key string, h container.Handle) *LocalDispatcher

type NodeIntent

+ Attempt int

+ RecoveryContinue bool

type ResolvedInputs

+ IdleTimeout time.Duration

+ WorkflowDir string

type RunOptions

+ RunEnv map[string]string

type RunStartedData

+ SandboxMode string

v0.2.0

Jul 1, 2026

Changes in this version

type ResolvedInputs

+ OutputArtifact string

type WorkflowExportResult

+ func EvaluateExportsInDef(def *ir.LoadedDefinition, moduleID string, rs *RunState, wf *ir.Workflow, ...) (WorkflowExportResult, error)

v0.1.3

Jun 26, 2026

v0.1.2

Jun 26, 2026

v0.1.1

Jun 26, 2026

Changes in this version

+ type AdapterResolver interface

+ AgentResolver func() agent.Resolver

type DispatchResult

+ SessionRef string

+ SessionTranscript []byte

type LocalDispatcher

+ Blobs state.Blobs

+ RunState *RunState

+ func (d *LocalDispatcher) AgentResolver() agent.Resolver

type NodeCompletedData

+ SessionRef string

type ResolvedInputs

+ SessionConfigDirRel string

+ SessionDir string

type RunState

+ SessionRefs map[string]string

v0.1.0

Jun 24, 2026

Changes in this version

+ const AgentEventInlineThreshold

+ const AttemptPassed

+ const AttemptRejected

+ const AttemptSegmentPrefix

+ const BackendDocker

+ const BackendFake

+ const BackendNative

+ const CallWorkflowSegment

+ const EventAgentEvent

+ const EventBranchTaken

+ const EventCallStarted

+ const EventGateAttempt

+ const EventLoopIter

+ const EventMapFrontier

+ const EventMapItem

+ const EventNodeCompleted

+ const EventNodeFailed

+ const EventNodeInvalidated

+ const EventNodeSkipped

+ const EventNodeStarted

+ const EventReactRound

+ const EventRetryAttempt

+ const EventRunCancelled

+ const EventRunFinished

+ const EventRunPaused

+ const EventRunResumed

+ const EventRunStarted

+ const EventSignalReceived

+ const EventSkillsSelected

+ const GateSegmentPrefix

+ const ItemFailed

+ const ItemPassed

+ const ItemPruned

+ const ReasonImageUnavailable

+ const RootModuleID

+ var ErrAgentEventSinkBackpressure = errors.New("engine: agent event sink backpressure")

+ var ErrNodeNotImplemented = errors.New("engine: node kind not implemented")

+ var ErrUnsupportedKind = errors.New(...)

+ func AgentRuntimeRef(wf *ir.Workflow, moduleID, uses string) string

+ func AttemptPath(gatePath string, attempt int) string

+ func CallWorkflowRuntimePath(callPath string) string

+ func CheckRuntimesDrift(recorded, current []ResolvedRuntime) error

+ func ComputeNodeKey(subtreeDigest string, inputRefs []string, runtimePins []string) string

+ func ComputeRerunInvalidation(wf *ir.Workflow, rs *RunState, target string) ([]string, error)

+ func ComputeVerifyingTraceTarget(wf *ir.Workflow, rs *RunState) (string, error)

+ func ContainerSpecFor(wf *ir.Workflow, composeFiles map[string][]byte, name string) container.ContainerSpec

+ func ItemPath(mapPath string, item int) string

+ func ItemStepPath(mapPath string, item int, suffix string) string

+ func IterPath(bodyPath string, iter int) string

+ func LiveResumePreflightRequests(ld *ir.LoadedDefinition, rs *RunState, resolver agent.Resolver) ([]agent.LiveResumePreflightRequest, error)

+ func LoadRunStartedDefinitionSnapshot(blobs state.Blobs, ref string) (*ir.LoadedDefinition, error)

+ func ModelPath(roundPath string) string

+ func ParentPath(path string) (string, bool)

+ func QualifiedAssetKey(moduleID, assetID string) string

+ func QualifiedContainerKey(runtimeParent, container string) string

+ func ResolveRerunTarget(wf *ir.Workflow, rs *RunState, events []state.Event, arg string) (string, error)

+ func RoundPath(reactPath string, round int) string

+ func SplitContainerRef(ref string) (bare, service string)

+ func StepPathIndex(wf *ir.Workflow) map[string]string

+ func StoreRunStartedAssets(blobs state.Blobs, assets map[string]ir.LoadedAsset) (map[string]RunStartedAsset, error)

+ func StoreRunStartedAssetsForLoadedDefinition(blobs state.Blobs, ld *ir.LoadedDefinition) (map[string]RunStartedAsset, error)

+ func StoreRunStartedDefinitionSnapshot(blobs state.Blobs, ld *ir.LoadedDefinition) (string, error)

+ func ToolPath(roundPath string, j int) string

+ func ValidateAgainstSchema(raw []byte, schema *ir.JSONSchema) (map[string]any, error)

+ func ValidateArtifactContract(path string, content []byte, contract OutputFileContract) error

+ func ValidateJSONAgainstSchema(raw []byte, schema *ir.JSONSchema) (any, error)

+ func ValidateOutputMap(output map[string]any, schema *ir.JSONSchema) error

+ type AgentEventData struct

+ DisplayBytes int

+ DisplayClass string

+ DisplayIsError bool

+ DisplayLines int

+ DisplaySummary string

+ DisplayTool string

+ Kind string

+ Live bool

+ PayloadInline []byte

+ PayloadRef string

+ Size int

+ Stream string

+ type AttemptResult struct

+ AttemptOutcome string

+ N int

+ Verdict map[string]any

+ type BranchTakenData struct

+ Which string

+ type CallStartedData struct

+ InputFiles map[string]string

+ InputRef string

+ Runtimes []ResolvedRuntime

+ type CallStartedRecord struct

+ Input map[string]any

+ InputFiles map[string]string

+ InputRef string

+ Runtimes []ResolvedRuntime

+ type DispatchResult struct

+ AgentEvents []agent.AgentEvent

+ Container string

+ Err error

+ ExitCode *int

+ Files []container.CapturedFile

+ InputRefs []string

+ Live *LiveDispatchRecord

+ Metrics *agent.MetricSet

+ Node ir.Node

+ Outcome Outcome

+ Outputs map[string]any

+ RetryAfter time.Duration

+ SnapshotRef string

+ Stdout []byte

+ Transcript agent.ThreadTurn

+ func RunWithRetry(ctx context.Context, dispatcher Dispatcher, intent NodeIntent, ...) (DispatchResult, <-chan container.IOChunk, error)

+ type Dispatcher interface

+ Run func(ctx context.Context, intent NodeIntent) (DispatchResult, <-chan container.IOChunk, error)

+ type ErrContainerRequired struct

+ Ref string

+ func (e *ErrContainerRequired) Error() string

+ type ErrRuntimeDrift struct

+ Container string

+ Current string

+ Recorded string

+ Ref string

+ func (e *ErrRuntimeDrift) Error() string

+ type GateAttemptData struct

+ AttemptOutcome string

+ N int

+ VerdictRef string

+ type LiveDispatchRecord struct

+ ActiveTurnID string

+ AdapterRef string

+ CommittedUnix int64

+ Epoch uint32

+ LeaseID string

+ NodePath string

+ ProviderTurnID string

+ RunID string

+ SessionKey string

+ SessionKeyHash string

+ type LiveHomePin struct

+ Digest string

+ Path string

+ type LocalDispatcher struct

+ AgentEventTap io.Writer

+ Backend container.Backend

+ ComposeFiles map[string][]byte

+ Handles map[string]container.Handle

+ RenderAgentEvent func(io.Writer, agent.AgentEvent)

+ Resolver agent.Resolver

+ RuntimeParent string

+ StepCostLine bool

+ func (d *LocalDispatcher) Run(ctx context.Context, intent NodeIntent) (DispatchResult, <-chan container.IOChunk, error)

+ func (d *LocalDispatcher) WithItemHandle(name string, h container.Handle) *LocalDispatcher

+ type LoopIterData struct

+ N int

+ type MapFrontierData struct

+ Items []MapItemData

+ type MapItemData struct

+ Cause string

+ ImageDigest string

+ N int

+ Outcome string

+ Reason string

+ Status string

+ type MapItemRecord struct

+ Cause string

+ ImageDigest string

+ ItemValue any

+ N int

+ Outcome string

+ Reason string

+ Status string

+ type NodeCompletedData struct

+ Container string

+ ExitCode *int

+ Files map[string]string

+ Metrics *agent.MetricSet

+ NodeKey string

+ NodeSubtreeDigest string

+ Outcome string

+ OutputsRef string

+ SnapshotRef string

+ StdoutRef string

+ TranscriptRef string

+ type NodeFailedData struct

+ Error string

+ Outcome string

+ func NodeFailedDataFromEvent(e state.Event) (NodeFailedData, error)

+ type NodeIntent struct

+ IdempotencyKey string

+ IsGateEvaluate bool

+ Node ir.Node

+ Path string

+ ResolvedInputs ResolvedInputs

+ RunContext agent.RunContext

+ type NodeInvalidatedData struct

+ Paths []string

+ type NodeResult struct

+ ExitCode *int

+ Files map[string]string

+ NodeKey string

+ NodeSubtreeDigest string

+ Outcome Outcome

+ Outputs map[string]any

+ OutputsRef string

+ Stdout []byte

+ StdoutRef string

+ Transcript agent.ThreadTurn

+ func Commit(log state.Log, blobs state.Blobs, path string, dr DispatchResult, ...) (NodeResult, error)

+ type NodeSkippedData struct

+ Path string

+ Reason string

+ type NodeStartedData struct

+ Kind string

+ type Outcome string

+ const OutcomeOK

+ const OutcomePermanentFailure

+ const OutcomeRejected

+ const OutcomeRetryableFailure

+ func ClassifyOutcome(exitCode int, awfParseErr error, callErr error, nonRetryableExitCodes []int) Outcome

+ func ParseOutcome(s string) (Outcome, error)

+ func Run(ctx context.Context, def *ir.LoadedDefinition, runstate *RunState, ...) (Outcome, error)

+ type OutputFileContract struct

+ Format string

+ Schema *ir.JSONSchema

+ type PauseMarker struct

+ NodePath string

+ Reason string

+ type ReactRoundData struct

+ N int

+ type ReactRoundRecord struct

+ N int

+ type ResolvedInputs struct

+ Command string

+ ContainerlessFiles []agent.InputFile

+ ContextEvidence []agent.ThreadTurn

+ Env map[string]string

+ Feedback ir.RawConfig

+ InputFiles []container.InputFile

+ NonRetryableExitCodes []int

+ OutputFileContracts map[string]OutputFileContract

+ OutputFiles []string

+ OutputSchema *ir.JSONSchema

+ Snapshot string

+ Thread []agent.ThreadTurn

+ Timeout time.Duration

+ Uses string

+ With ir.RawConfig

+ type ResolvedRuntime struct

+ Container string

+ Ref string

+ Version string

+ func ResolveRuntimes(ctx context.Context, refs []RuntimeRef, resolver agent.Resolver, ...) ([]ResolvedRuntime, error)

+ type RetryAttemptData struct

+ Error string

+ N int

+ Outcome string

+ type RunCancelledData struct

+ Reason string

+ type RunFinishedData struct

+ Outcome string

+ func RunFinishedDataFromEvent(e state.Event) (RunFinishedData, error)

+ type RunOptions struct

+ Assets map[string]RunStartedAsset

+ Broker *signal.Broker

+ InputFiles map[string]string

+ LiveFinalizer func(context.Context, LiveDispatchRecord) error

+ RerunFrom string

+ Resume bool

+ Tap io.Writer

+ type RunPausedData struct

+ NodePath string

+ Reason string

+ type RunResumedData struct

+ Epoch uint32

+ type RunStartedAsset struct

+ DeclaredPath string

+ Files []RunStartedAssetFile

+ IsDir bool

+ type RunStartedAssetFile struct

+ Path string

+ Ref string

+ SHA256 string

+ Size int64

+ type RunStartedData struct

+ Assets map[string]RunStartedAsset

+ Backend string

+ DefinitionRef string

+ InputFiles map[string]string

+ InputRef string

+ LiveHome *LiveHomePin

+ RunID string

+ Runtimes []ResolvedRuntime

+ StructuralDigest string

+ WorkflowDigest string

+ WorkflowID string

+ WorkflowVersion int

+ func RunStartedDataFromEvents(events []state.Event) (RunStartedData, error)

+ type RunState struct

+ Assets map[string]RunStartedAsset

+ Branches map[string]string

+ CallStarted map[string]CallStartedRecord

+ CancelReason string

+ Cancelled bool

+ Completed map[string]NodeResult

+ Epoch uint32

+ GateAttempts map[string][]AttemptResult

+ Input map[string]any

+ InputFiles map[string]string

+ LoopIters map[string]int

+ MapItems map[string][]MapItemRecord

+ Paused *PauseMarker

+ ReactRounds map[string][]ReactRoundRecord

+ RunID string

+ SelectedSkills map[string]SkillsSelectedData

+ SignalReceivedAt map[string]SignalReceivedEntry

+ Signals map[string][]SignalEntry

+ SnapshotRefs map[string]string

+ StructuralDigest string

+ WorkflowDigest string

+ func Fold(events []state.Event, blobs state.Blobs) (*RunState, error)

+ func NewRunState(runID, workflowDigest string, input map[string]any) *RunState

+ func (rs *RunState) AppendSignal(name string, e SignalEntry)

+ func (rs *RunState) CallStartedPaths() []string

+ func (rs *RunState) IsCancelled() bool

+ func (rs *RunState) LookupBranch(path string) (string, bool)

+ func (rs *RunState) LookupCallStarted(path string) (CallStartedRecord, bool)

+ func (rs *RunState) LookupCancelReason() string

+ func (rs *RunState) LookupCompleted(path string) (NodeResult, bool)

+ func (rs *RunState) LookupGateAttempts(gatePath string) []AttemptResult

+ func (rs *RunState) LookupLoopIters(path string) int

+ func (rs *RunState) LookupMapItems(mapPath string) []MapItemRecord

+ func (rs *RunState) LookupPaused() *PauseMarker

+ func (rs *RunState) LookupReactRounds(r string) []ReactRoundRecord

+ func (rs *RunState) LookupSelectedSkills(path string) (SkillsSelectedData, bool)

+ func (rs *RunState) LookupSignalReceivedAt(path string) (SignalReceivedEntry, bool)

+ func (rs *RunState) LookupSignals(name string) []SignalEntry

+ func (rs *RunState) RecordBranch(path string, which string)

+ func (rs *RunState) RecordCallStarted(path string, rec CallStartedRecord)

+ func (rs *RunState) RecordCompleted(path string, nr NodeResult)

+ func (rs *RunState) RecordGateAttempt(gatePath string, ar AttemptResult)

+ func (rs *RunState) RecordLoopIter(path string, k int)

+ func (rs *RunState) RecordMapItem(mapPath string, mr MapItemRecord)

+ func (rs *RunState) RecordReactRound(r string, rr ReactRoundRecord)

+ func (rs *RunState) RecordSelectedSkills(path string, data SkillsSelectedData)

+ func (rs *RunState) RecordSignalReceivedAt(path string, e SignalReceivedEntry)

+ func (rs *RunState) SetCancelReason(reason string)

+ func (rs *RunState) SetCancelled(v bool)

+ func (rs *RunState) SetPaused(pm *PauseMarker)

+ func (rs *RunState) UpdateMapItemValue(mapPath string, n int, value any)

+ type RuntimeRef struct

+ Container string

+ ModuleID string

+ NodePath string

+ RuntimeParent string

+ Uses string

+ func WalkRuntimeRefs(moduleID, runtimeParent string, wf *ir.Workflow) []RuntimeRef

+ type Scope struct

+ func NewScope(rs *RunState, wf *ir.Workflow, ctxPath string) *Scope

+ func NewScopeWithInput(rs *RunState, wf *ir.Workflow, ctxPath string, input map[string]any) *Scope

+ func NewScopeWithInputAndFiles(rs *RunState, wf *ir.Workflow, ctxPath string, input map[string]any, ...) *Scope

+ func NewScopeWithVerdict(rs *RunState, wf *ir.Workflow, ctxPath string, verdict map[string]any) *Scope

+ func (s *Scope) Resolve(ref *template.Ref) (any, error)

+ func (s *Scope) ResolveArtifactPath(id, containerPath string) (string, error)

+ func (s *Scope) ResolveDeclaredArtifactPath(id, declaredPath string) (string, error)

+ func (s *Scope) ResolveWorkflowInputFile(name string) (string, error)

+ type SelectedSkill struct

+ ID string

+ Score float64

+ type SignalEntry struct

+ PayloadRef string

+ Seq int

+ type SignalReceivedData struct

+ Name string

+ PayloadRef string

+ Seq int

+ type SignalReceivedEntry struct

+ PayloadRef string

+ Seq int

+ type SkillsSelectedData struct

+ Library string

+ LibraryDigest string

+ Router string

+ RouterParams map[string]float64

+ RouterVersion string

+ Selected []SelectedSkill

+ type SkipUnwind struct

+ Reason string

+ TargetPath string

+ func (e *SkipUnwind) Error() string

+ type WorkflowExportResult struct

+ Files map[string]string

+ Outputs map[string]any

+ func EvaluateExports(rs *RunState, wf *ir.Workflow, ctxPath string, input map[string]any, ...) (WorkflowExportResult, error)

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