Versions in this module Expand all Collapse all v0 v0.0.5 Jun 2, 2026 Changes in this version + const MetadataOnlyCommandEnvValue + const RedactedCommandEnvValue + const WorkLogEventCommandRunnerCompleted + const WorkLogEventCommandRunnerOutputDetails + const WorkLogEventCommandRunnerRequestDetails + const WorkLogEventCommandRunnerRequested + const WorkLogEventWorkerPoolExecutorEntered + const WorkLogEventWorkerPoolResponseSubmitted + const WorkLogEventWorkerPoolSubmitted + func CommandRequestInputTokens(request CommandRequest) []interfaces.Token + func InputTokens(tokens ...interfaces.Token) []any + func PanicAsFailedResult(dispatch interfaces.WorkDispatch, recovered any, duration time.Duration) interfaces.WorkResult + func ResolveModelOperationBindings(workstationDef *interfaces.FactoryWorkstationConfig, ...) ([]interfaces.ResolvedModelOperationBinding, error) + func WorkDispatchInputTokens(dispatch interfaces.WorkDispatch) []interfaces.Token + func WorkLogFields(metadata interfaces.ExecutionMetadata, keysAndValues ...any) []any + type AgentContext struct + OutputSchema []byte + SystemPrompt string + Tools []Tool + UserMessage string + type AgentExecutor struct + func NewAgentExecutor(runtimeConfig interfaces.RuntimeDefinitionLookup, provider Provider, ...) *AgentExecutor + func NewAgentExecutorWithRunner(runtimeConfig interfaces.RuntimeDefinitionLookup, runner Runner, ...) *AgentExecutor + func (ae *AgentExecutor) Execute(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error) + type AgentExecutorOption func(*AgentExecutor) + func WithLogger(logger logging.Logger) AgentExecutorOption + type CommandRequest = workerprocess.CommandRequest + type CommandResult = workerprocess.CommandResult + type CommandRunner = workerprocess.CommandRunner + type DefaultPromptRenderer = workerprompting.DefaultPromptRenderer + type ExecCommandRunner = workerprocess.ExecCommandRunner + type LoggingCommandRunner = workerprocess.LoggingCommandRunner + type NoopExecutor struct + func (n *NoopExecutor) Execute(_ context.Context, d interfaces.WorkDispatch) (interfaces.WorkResult, error) + type OutputParser interface + ParseJSON func(response string, schema []byte) ([]interfaces.TokenColor, error) + type Provider = workerprovider.Provider + type ProviderError = workerprovider.ProviderError + type Runner interface + Execute func(ctx context.Context, request interfaces.RunnerExecutionRequest) (interfaces.RunnerExecutionResult, error) + func RunnerFromProvider(provider Provider) Runner + type ScriptEventRecorder func(factoryapi.FactoryEvent) + type ScriptExecutor struct + Args []string + Command string + CommandRunner CommandRunner + FactoryDir string + Logger logging.Logger + func NewScriptExecutor(def *interfaces.WorkerConfig, logger logging.Logger, ...) *ScriptExecutor + func NewScriptExecutorWithRunner(def *interfaces.WorkerConfig, runner CommandRunner, logger logging.Logger, ...) *ScriptExecutor + func (se *ScriptExecutor) Execute(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error) + type ScriptExecutorOption func(*ScriptExecutor) + func WithScriptClock(now func() time.Time) ScriptExecutorOption + func WithScriptEventRecorder(recorder ScriptEventRecorder) ScriptExecutorOption + func WithScriptFactoryDir(factoryDir string) ScriptExecutorOption + type Tool struct + Description string + Name string + type WorkerExecutor interface + Execute func(ctx context.Context, dispatch interfaces.WorkDispatch) (interfaces.WorkResult, error) + type WorkerPool struct + 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 struct + func NewWorkerRunner(workerType string, executor WorkerExecutor, ...) *WorkerRunner + func (r *WorkerRunner) Start() + func (r *WorkerRunner) Stop() + type WorkstationExecutor struct + DefaultRunnerID string + Executor WorkstationRequestExecutor + GitCommander worktree.GitCommander + Logger logging.Logger + Parser OutputParser + Renderer workerprompting.PromptRenderer + RuntimeConfig interfaces.RuntimeConfigLookup + func (we *WorkstationExecutor) Execute(ctx context.Context, dispatch interfaces.WorkDispatch) (interfaces.WorkResult, error) + type WorkstationRequestExecutor interface + Execute func(ctx context.Context, request interfaces.WorkstationExecutionRequest) (interfaces.WorkResult, error)
Go to main page