engine

package

Go to main page

Versions in this module

v0

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