executor

type AgentContext ¶

type AgentContext struct {
	SystemPrompt string `json:"system_prompt"` // worker AGENTS.md body
	UserMessage  string `json:"user_message"`  // rendered workstation prompt
	Tools        []Tool `json:"tools,omitempty"`
	OutputSchema []byte `json:"output_schema,omitempty"`
}

AgentContext is the merged execution context assembled from worker AGENTS.md + workstation AGENTS.md at execution time.

type AgentExecutor ¶

type AgentExecutor struct {
	// contains filtered or unexported fields
}

AgentExecutor implements WorkstationRequestExecutor for MODEL_WORKER types. It reads prompt/output inputs resolved by WorkstationExecutor, calls the configured Provider for inference, and maps the response to a WorkResult.

func NewAgentExecutor(runtimeConfig interfaces.RuntimeDefinitionLookup, provider Provider, opts ...AgentExecutorOption) *AgentExecutor

func NewAgentExecutorWithRunner(runtimeConfig interfaces.RuntimeDefinitionLookup, runner Runner, opts ...AgentExecutorOption) *AgentExecutor

func (ae *AgentExecutor) Execute(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error)

type AgentExecutorOption ¶

type AgentExecutorOption func(*AgentExecutor)

AgentExecutorOption configures an AgentExecutor.

func WithLogger(logger logging.Logger) AgentExecutorOption

type CommandRequest ¶

type CommandRequest = workerprocess.CommandRequest

type CommandResult ¶

type CommandResult = workerprocess.CommandResult

type CommandRunner ¶

type CommandRunner = workerprocess.CommandRunner

type DefaultPromptRenderer ¶

type DefaultPromptRenderer = workerprompting.DefaultPromptRenderer

type ExecCommandRunner ¶

type ExecCommandRunner = workerprocess.ExecCommandRunner

type LoggingCommandRunner ¶

type LoggingCommandRunner = workerprocess.LoggingCommandRunner

type NoopExecutor ¶

type NoopExecutor struct{}

NoopExecutor is a WorkerExecutor that always returns OutcomeAccepted without calling any LLM or script. It is used as a fallback when no AGENTS.md is configured for a worker, allowing tests to exercise the petri-net topology without providing real worker configuration.

func (n *NoopExecutor) Execute(_ context.Context, d interfaces.WorkDispatch) (interfaces.WorkResult, error)

type OutputParser ¶

type OutputParser interface {
	ParseJSON(response string, schema []byte) ([]interfaces.TokenColor, error)
}

OutputParser parses structured output from a worker execution response.

type Provider ¶

type Provider = workerprovider.Provider

type ProviderError ¶

type ProviderError = workerprovider.ProviderError

type Runner ¶

type Runner interface {
	Execute(ctx context.Context, request interfaces.RunnerExecutionRequest) (interfaces.RunnerExecutionResult, error)
}

Runner executes one normalized runner request.

func RunnerFromProvider(provider Provider) Runner

type ScriptEventRecorder ¶

type ScriptEventRecorder func(factoryapi.FactoryEvent)

ScriptEventRecorder receives generated script-boundary events.

type ScriptExecutor ¶

type ScriptExecutor struct {
	Command       string
	Args          []string
	FactoryDir    string
	CommandRunner CommandRunner
	Logger        logging.Logger
	// contains filtered or unexported fields
}

ScriptExecutor implements WorkstationRequestExecutor by running shell commands via os/exec. It supports template substitution in args using the PromptData model (e.g., {{ (index .Inputs 0).Name }}, {{ (index .Inputs 0).WorkID }}, {{ index (index .Inputs 0).Tags "key" }}, {{ .Context.WorkDir }}) and merges dispatch env vars into the process environment. TODO: consider names for various things.

func NewScriptExecutor(def *interfaces.WorkerConfig, logger logging.Logger, opts ...ScriptExecutorOption) *ScriptExecutor

func NewScriptExecutorWithRunner(def *interfaces.WorkerConfig, runner CommandRunner, logger logging.Logger, opts ...ScriptExecutorOption) *ScriptExecutor

func (se *ScriptExecutor) Execute(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error)

type ScriptExecutorOption ¶

type ScriptExecutorOption func(*ScriptExecutor)

ScriptExecutorOption configures a ScriptExecutor.

func WithScriptClock(now func() time.Time) ScriptExecutorOption

func WithScriptEventRecorder(recorder ScriptEventRecorder) ScriptExecutorOption

func WithScriptFactoryDir(factoryDir string) ScriptExecutorOption

type Tool ¶

type Tool struct {
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
}

Tool describes a tool available to the agent during execution.

type WorkerExecutor ¶

type WorkerExecutor interface {
	Execute(ctx context.Context, dispatch interfaces.WorkDispatch) (interfaces.WorkResult, error)
}

WorkerExecutor is the side-effect interface for one dispatched worker step.

type WorkerPool ¶

type WorkerPool struct {
	// contains filtered or unexported fields
}

WorkerPool manages WorkerRunners by worker type, providing a shared resultCh that the engine selects on to wake when workers complete.

func NewWorkerPool(logger logging.Logger) *WorkerPool

func (p *WorkerPool) Dispatch(workerType string, dispatch interfaces.WorkDispatch) bool

func (p *WorkerPool) Register(workerType string, executor WorkerExecutor)

func (p *WorkerPool) ResultCh() <-chan interfaces.WorkResult

func (p *WorkerPool) Start()

func (p *WorkerPool) Stop()

type WorkerRunner ¶

type WorkerRunner struct {
	// contains filtered or unexported fields
}

WorkerRunner is an active goroutine that processes work for a specific worker type. It reads WorkDispatches from its dispatchCh, calls WorkerExecutor.Execute, and sends the WorkResult to the shared resultCh.

func NewWorkerRunner(workerType string, executor WorkerExecutor, resultCh chan<- interfaces.WorkResult, logger logging.Logger) *WorkerRunner

func (r *WorkerRunner) Start()

func (r *WorkerRunner) Stop()

type WorkstationExecutor ¶

type WorkstationExecutor struct {
	RuntimeConfig   interfaces.RuntimeConfigLookup
	DefaultRunnerID string
	Executor        WorkstationRequestExecutor
	Renderer        workerprompting.PromptRenderer
	Parser          OutputParser
	Logger          logging.Logger        // optional; nil → noop
	GitCommander    worktree.GitCommander // optional; nil → ExecGitCommander
}

WorkstationExecutor wraps a WorkerExecutor with workstation-specific prompt rendering. This is what the Dispatcher actually calls.

For MODEL_WORKSTATION: render prompt → call executor → parse output → WorkResult For LOGICAL_MOVE: pass-through input colors → WorkResult (no worker call)

func (we *WorkstationExecutor) Execute(ctx context.Context, dispatch interfaces.WorkDispatch) (interfaces.WorkResult, error)

type WorkstationRequestExecutor ¶

type WorkstationRequestExecutor interface {
	Execute(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error)
}

WorkstationRequestExecutor handles worker-owned execution after workstation prompt and runtime context resolution.