Versions in this module Expand all Collapse all v1 v1.0.9 Feb 18, 2026 v1.0.8 Feb 17, 2026 v1.0.7 Feb 17, 2026 v1.0.6 Feb 16, 2026 v1.0.5 Feb 15, 2026 v1.0.4 Feb 9, 2026 Changes in this version type StageInput + ExtraEnv map[string]string + ExtraPromptPath []string + TaskPromptPath string v1.0.3 Feb 9, 2026 v1.0.2 Feb 8, 2026 v1.0.1 Feb 6, 2026 v1.0.0 Feb 6, 2026 Changes in this version + func IsCodexCommand(cfg config.Config, role index.Role) (bool, error) + func ReadAgentPID(workerStateDir string) (int, bool, error) + func ResolveCommand(cfg config.Config, role index.Role, taskPath string, repoRoot string, ...) ([]string, error) + type AuditLogger interface + LogWorkerTimeout func(taskID string, role string, timeoutSecs int, worktreePath string) error + type DispatchInput struct + Command []string + EnvVars map[string]string + SelectedCLI string + Stage roles.Stage + TaskID string + Warn func(string) + WorkDir string + WorkerStateDir string + type DispatchResult struct + ExitPath string + PID int + StartedAt time.Time + StderrPath string + StdoutPath string + WorkerStateDir string + func DispatchWorker(input DispatchInput) (DispatchResult, error) + func DispatchWorkerFromConfig(cfg config.Config, task index.Task, stageResult StageResult, workDir string, ...) (DispatchResult, error) + type ExecInput struct + AuditLogger AuditLogger + Command []string + EnvVars map[string]string + Role string + TaskID string + TimeoutSecs int + Warn func(string) + WorkDir string + WorkerStateDir string + WorktreePath string + type ExecResult struct + Duration time.Duration + Error error + ExitCode int + StderrPath string + StdoutPath string + TimedOut bool + func ExecuteWorker(input ExecInput) (ExecResult, error) + func ExecuteWorkerFromConfig(cfg config.Config, task index.Task, stageResult StageResult, workDir string, ...) (ExecResult, error) + func ExecuteWorkerFromConfigWithAudit(cfg config.Config, task index.Task, stageResult StageResult, workDir string, ...) (ExecResult, error) + type ExitStatus struct + DurationMs int64 + ExitCode int + FinishedAt time.Time + PID int + TokensPrompt int + TokensResponse int + TokensTotal int + func ReadExitStatus(workerStateDir string, taskID string, stage roles.Stage) (ExitStatus, bool, error) + type IngestInput struct + ExecResult ExecResult + ExitStatus *ExitStatus + Stage roles.Stage + TaskID string + Warn func(string) + WorktreePath string + type IngestResult struct + BlockReason string + HasCommit bool + HasMarker bool + MarkerExists bool + MarkerPath string + Metrics index.ExecutionMetrics + NewState index.TaskState + Success bool + TimedOut bool + func CompletionResultToIngest(taskID string, stage roles.Stage, completion StageCompletion) (IngestResult, error) + func IngestWorkerResult(input IngestInput) (IngestResult, error) + type StageCompletion struct + Completed bool + HasCommit bool + HasMarker bool + MarkerFound bool + MarkerPath string + func CheckStageCompletion(worktreePath string, workerStateDir string, stage roles.Stage) (StageCompletion, error) + type StageInput struct + AgentUsesCodex bool + ReasoningEffort string + RepoRoot string + Role index.Role + Stage roles.Stage + Task index.Task + Warn func(string) + WorkerStateDir string + WorktreeRoot string + type StageResult struct + Env map[string]string + EnvPath string + PromptFiles []string + PromptListPath string + PromptPath string + ReasoningEffort string + WorkerStateDir string + func StageEnvAndPrompts(input StageInput) (StageResult, error)