runner

Oct 14, 2026

Changes in this version

+ func ParseApprovalOption(args []string) (token string, remaining []string, err error)

+ type ApprovalSuspension struct

+ ExecutionID string

+ ExpiresAt time.Time

+ Gate string

+ InputHash string

+ Persisted bool

+ Reason string

+ Role string

+ SourceHash string

+ SourceName string

+ SuspendedAt time.Time

type Config

+ IdempotencyStore action.IdempotencyStore

+ Journal action.Journal

+ type DurabilityOptions struct

+ ExecutionID string

+ JournalDir string

+ func ParseDurabilityOptions(args []string) (DurabilityOptions, []string, error)

type Execution

+ ExecutionID string

+ Suspension *ApprovalSuspension

+ type FileJournal struct

+ func NewFileJournal(dir string) (*FileJournal, error)

+ func (j *FileJournal) Claim(ctx context.Context, key, requestHash string, leaseTTL time.Duration) (action.IdempotencyClaim, error)

+ func (j *FileJournal) ClearApprovalSuspension(ctx context.Context, executionID string) error

+ func (j *FileJournal) Close() error

+ func (j *FileJournal) Complete(ctx context.Context, key, token string, entry action.IdempotencyEntry, ...) error

+ func (j *FileJournal) Get(ctx context.Context, key string) (action.IdempotencyEntry, bool)

+ func (j *FileJournal) GetStep(ctx context.Context, executionID, stepName string) (data []byte, found bool, readErr error)

+ func (j *FileJournal) LoadApprovalSuspension(ctx context.Context, executionID string) (ApprovalSuspension, bool, error)

+ func (j *FileJournal) RecordStep(ctx context.Context, executionID, stepName string, data []byte) error

+ func (j *FileJournal) Release(ctx context.Context, key, token string) error

+ func (j *FileJournal) RenewClaim(ctx context.Context, key, token string, leaseTTL time.Duration) error

+ func (j *FileJournal) SaveApprovalSuspension(ctx context.Context, suspension ApprovalSuspension) error

+ func (j *FileJournal) Set(ctx context.Context, key string, entry action.IdempotencyEntry, ...)

type Opts

+ ApprovalToken string

+ ExecutionID string

+ JournalDir string

+ type SuspensionStore interface

+ ClearApprovalSuspension func(ctx context.Context, executionID string) error

+ LoadApprovalSuspension func(ctx context.Context, executionID string) (ApprovalSuspension, bool, error)

+ SaveApprovalSuspension func(ctx context.Context, suspension ApprovalSuspension) error

Oct 13, 2026

Changes in this version

type Config

+ FileResolver xfile.Resolver

Oct 12, 2026

Changes in this version

+ func EvaluateAssertions(result any, asserts []string, ...) []error

+ func EvaluateAssertionsContext(ctx context.Context, result any, asserts []string, ...) []error

+ func RunAssertionsContext(ctx context.Context, w io.Writer, result any, durationMS int64, ...) int

Oct 11, 2026

Changes in this version

+ func RunLean(ctx context.Context, source, name string, bundles []core.Bundle, args []string) int

type Compilation

+ func CompileWithOptions(ctx context.Context, cfg Config, src, name string, ...) (Compilation, error)

Oct 6, 2026

Changes in this version

+ func Preflight(ctx context.Context, cfg Config, src, name string) (*core.PreparedSource, error)

+ type EntryPoint struct

+ Name string

+ Payload any

type Execution

+ func ExecutePrepared(ctx context.Context, cfg Config, prepared *core.PreparedSource, ...) (Execution, error)

Oct 5, 2026

Changes in this version

+ var ErrHostAlreadyRunning = errors.New("runner: host invocation is already running")

+ var ErrHostInvocationRunning = errors.New("runner: host invocation is still running")

+ var ErrHostShutdownStarted = errors.New("runner: host shutdown has started")

+ type Host struct

+ func NewHost(opts ...HostOption) *Host

+ func (h *Host) Own(bundle core.Bundle) error

+ func (h *Host) OwnAll(bundles []core.Bundle) error

+ func (h *Host) Run(ctx context.Context, fn func(context.Context) error) (result error)

+ func (h *Host) Shutdown(ctx context.Context) error

+ type HostOption func(*hostOptions)

+ func WithShutdownTimeout(timeout time.Duration) HostOption

Oct 4, 2026

Changes in this version

+ func PrintInfoJSON(w io.Writer, path string, meta map[string]any, ast core.Expr) error

+ func SplitPipelineModifiers(table *core.ModifierTable, mods []string) (wrapper, body []string)

+ type Compilation struct

+ Meta map[string]any

+ Program action.AnyAction

+ Resolver core.CapabilityResolver

+ func Compile(ctx context.Context, cfg Config, src, name string) (Compilation, error)

type Config

+ ArgSchemas map[string][]core.ArgFieldSpec

+ func (c Config) PrimariesFor(meta map[string]any, parent ...core.PrimaryExtension) *core.PrimaryExtensionTable

type Execution

+ Resolver core.CapabilityResolver

+ type InfoShape struct

+ Asserts []string

+ Atoms []string

+ Description string

+ Path string

+ type SourcedModifier struct

+ Raw string

+ Source core.ModifierSource

+ func SplitPipelineModifiersWithSources(table *core.ModifierTable, mods []string, sources []core.ModifierSource) (wrapper, body []SourcedModifier)

Oct 1, 2026

Changes in this version

+ func FormatDuration(d time.Duration) string

+ func JSONMapView(value any) any

+ func PrintInfo(w io.Writer, path, _ string, meta map[string]any, ast core.Expr) int

+ func Run(ctx context.Context, cfg Config, path string, payload map[string]any, ...) int

+ func RunSource(ctx context.Context, cfg Config, src, name string, payload map[string]any, ...) int

+ type Config struct

+ CompileOpts []core.CompileOption

+ Directives *core.DirectiveTable

+ EventSink observe.Sink

+ Hooks []action.AnyHook

+ Materializers []core.Materializer

+ MeasureAllocs bool

+ Modifiers *core.ModifierTable

+ Operators *core.OperatorTable

+ Primaries *core.PrimaryExtensionTable

+ Resolver core.CapabilityResolver

+ func BuildConfig(bundles []core.Bundle) (Config, error)

+ type Execution struct

+ CompileAllocBytes uint64

+ CompileAllocs uint64

+ CompileDuration time.Duration

+ Meta map[string]any

+ Output any

+ RunAllocBytes uint64

+ RunAllocs uint64

+ RunDuration time.Duration

+ func Execute(ctx context.Context, cfg Config, src, name string, payload map[string]any) (Execution, error)

+ type Observer struct

+ func NewObserver(out io.Writer, verbosity int) *Observer

+ func (o *Observer) ActionNames() []string

+ func (o *Observer) Hook() action.AnyHook

+ func (o *Observer) PrintSummary(w io.Writer)

+ func (o *Observer) Records() []Record

+ type Opts struct

+ Asserts []string

+ Info bool

+ Stderr io.Writer

+ Stdout io.Writer

+ Verbosity int

+ type Record struct

+ Action string

+ Duration time.Duration

+ Err error

+ Start time.Time

Sep 25, 2026

Changes in this version

+ func RunFlow(ctx context.Context, req Request) int

Sep 23, 2026

Changes in this version

+ const VerbosityData

+ const VerbosityLifecycle

+ const VerbositySilent

+ const VerbositySummary

+ const VerbosityTiming

+ func ManifestHash(modules []RequiredModule, opts map[string]map[string]string) string

+ func MaterializeForTest(pre *directives.Preprocessed, base *action.Registry) (*action.Registry, error)

+ func ParseOptions(pre *directives.Preprocessed, importPath string) map[string]string

+ func RegisterMaterializer(m DeclMaterializer)

+ func RunFlowTest(ctx context.Context, path string, reg *action.Registry, opts TestOptions) int

+ func ValidateOptions(opts map[string]string, allowed ...string) error

type Checkpoint

+ Suspended bool

+ type DeclMaterializer interface

+ Key func() string

+ Materialize func(decls any, base *action.Registry) ([]action.AnyAction, error)

+ type ModuleAllowlist map[string]bool

+ type Registrar func(opts map[string]string, sink observe.Sink) (action.Library, error)

+ type RequiredModule struct

+ Import string

+ Local bool

+ Version string

+ type RequiresPlan struct

+ Modules []RequiredModule

+ func AnalyzeRequires(pre *directives.Preprocessed, allow ModuleAllowlist) (*RequiresPlan, error)

type RunnerObserver

+ func (o *RunnerObserver) LogData(ctx context.Context, phase string, payload any)

+ func (o *RunnerObserver) LogLifecycle(ctx context.Context, phase, msg string, fields ...any)

+ func (o *RunnerObserver) LogTiming(ctx context.Context, phase, msg string, fields ...any)

+ func (o *RunnerObserver) OnSecurity(_ context.Context, ev flow.SecurityEvent)

+ type TestOptions struct

+ ExpectPath string

+ MockPath string

+ PayloadPath string

+ Stderr io.Writer

+ Stdout io.Writer

+ Verbosity int

Sep 15, 2026

Changes in this version

+ func ExecSelf(ctx context.Context, binary string, args []string) int

+ func PrintFlowInfo(ctx context.Context, out io.Writer, req Request, reg *flow.MapRegistry) int

+ func ResolveRequires(ctx context.Context, reqs []flow.Requirement, stdout, stderr *os.File) (string, error)

+ func RunAssertions(result any, assertions []string, metrics *RunnerObserver) int

+ func RunWithRegistry(ctx context.Context, req Request, reg *flow.MapRegistry, ...) int

+ type ApprovalMode string

+ const ApprovalAll

+ const ApprovalDanger

+ const ApprovalNone

+ type Checkpoint struct

+ Flow string

+ FlowHash string

+ Layer int

+ RunID string

+ SavedAt time.Time

+ SpentMicros int64

+ State map[string]any

+ type CheckpointStore interface

+ Delete func(ctx context.Context, runID string) error

+ Load func(ctx context.Context, runID string) (Checkpoint, bool, error)

+ Save func(ctx context.Context, cp Checkpoint) error

+ type Default struct

+ Observer *RunnerObserver

+ func (d Default) RunFlow(ctx context.Context, path string, payload map[string]any, args []string, ...) int

+ func (d Default) RunWithRegistry(ctx context.Context, req Request, reg *flow.MapRegistry, obs *RunnerObserver) int

+ type FieldDoc struct

+ Key string

+ Name string

+ Required bool

+ Type string

+ Validation string

+ type FileCheckpointStore struct

+ func NewFileCheckpointStore(baseDir string) (*FileCheckpointStore, error)

+ func (s *FileCheckpointStore) Delete(ctx context.Context, runID string) error

+ func (s *FileCheckpointStore) Load(ctx context.Context, runID string) (Checkpoint, bool, error)

+ func (s *FileCheckpointStore) Save(ctx context.Context, cp Checkpoint) error

+ type FlowStep struct

+ Name string

+ Prompt string

+ type MemoryCheckpointStore struct

+ func NewMemoryCheckpointStore() *MemoryCheckpointStore

+ func (s *MemoryCheckpointStore) Delete(ctx context.Context, runID string) error

+ func (s *MemoryCheckpointStore) Load(ctx context.Context, runID string) (Checkpoint, bool, error)

+ func (s *MemoryCheckpointStore) Save(ctx context.Context, cp Checkpoint) error

+ type MetricRecord struct

+ Action string

+ CompTokens int

+ CostKnown bool

+ CostMicros int64

+ Currency cost.Currency

+ Duration time.Duration

+ ExecutionID string

+ PromptSnippet string

+ PromptTokens int

+ Success bool

+ type ObserverHooks struct

+ KnownModel func(model string) bool

+ PromptFromRequest func(req any) string

+ ResultSummary func(res any) string

+ TokensAndCost func(res any) (int, int, int64, cost.Currency, bool)

+ type Request struct

+ ApprovalMode ApprovalMode

+ Args []string

+ Assertions []string

+ BenchNode string

+ BenchRuns int

+ CacheDir string

+ Info bool

+ Metrics bool

+ OutDir string

+ OutFormat string

+ Path string

+ Payload map[string]any

+ Resume string

+ Stderr io.Writer

+ Stdout io.Writer

+ Store CheckpointStore

+ Verbosity int

+ type RunnerObserver struct

+ func NewRunnerObserver(out io.Writer, verbosity int) *RunnerObserver

+ func NewRunnerObserverWithHooks(out io.Writer, verbosity int, hooks ObserverHooks) *RunnerObserver

+ func (o *RunnerObserver) AddSpend(micros int64)

+ func (o *RunnerObserver) Emit(_ context.Context, ev observe.Event)

+ func (o *RunnerObserver) Hook() action.AnyHook

+ func (o *RunnerObserver) Out() io.Writer

+ func (o *RunnerObserver) PrintSummary(out io.Writer)

+ func (o *RunnerObserver) ProviderTrace(kind, provider, model string, in, out int, costMicro int64, dur time.Duration, ...)

+ func (o *RunnerObserver) SetVerbosity(n int)

+ func (o *RunnerObserver) TotalSpentMicros() int64

+ func (o *RunnerObserver) TotalTokens() int

+ func (o *RunnerObserver) Verbosity() int

+ type TerminalApprovalGate struct

+ func NewApprovalGate(mode ApprovalMode) *TerminalApprovalGate

+ func (g *TerminalApprovalGate) Check(ctx context.Context, actionName, argsJSON, token string) error