executor

Mar 3, 2026

Changes in this version

+ const ConventionalInitScript

+ const ConventionalTeardownScript

+ const DefaultSuspendIdleTimeout

+ const DefaultWorktreeCleanupMaxAge

+ const DoneTaskCleanupTimeout

+ const TmuxDaemonSession

+ var ConfigFileNames = []string

+ func CapturePaneContent(taskID int64, lines int) string

+ func ClaudeConfigFilePath(dir string) string

+ func ClaudeSessionExists(sessionID, workDir, configDir string) bool

+ func CleanupClaudeSessions(worktreePath, configDir string) error

+ func DefaultClaudeConfigDir() string

+ func DefaultExecutorName() string

+ func FindClaudeSessionID(workDir string) string

+ func GetClaudePIDFromPane(paneID string) int

+ func GetTasksWithRunningShellProcess() map[int64]bool

+ func GetWorktreeInitScript(projectDir string) string

+ func GetWorktreeTeardownScript(projectDir string) string

+ func HasRunningProcessInTaskUI() bool

+ func PurgeStaleClaudeProjectConfigs(configPath string) (int, error)

+ func RemoveClaudeProjectConfig(configPath, projectPath string) error

+ func RenameClaudeSession(workDir, newName, configDir string) error

+ func ResolveClaudeConfigDir(custom string) string

+ func SendKeyToPane(taskID int64, keys ...string) error

+ func TmuxSessionName(taskID int64) string

+ func TmuxWindowName(taskID int64) string

+ type ClaudeExecutor struct

+ func NewClaudeExecutor(e *Executor) *ClaudeExecutor

+ func (c *ClaudeExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (c *ClaudeExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (c *ClaudeExecutor) FindSessionID(workDir string) string

+ func (c *ClaudeExecutor) GetProcessID(taskID int64) int

+ func (c *ClaudeExecutor) IsAvailable() bool

+ func (c *ClaudeExecutor) IsSuspended(taskID int64) bool

+ func (c *ClaudeExecutor) Kill(taskID int64) bool

+ func (c *ClaudeExecutor) Name() string

+ func (c *ClaudeExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (c *ClaudeExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (c *ClaudeExecutor) ResumeProcess(taskID int64) bool

+ func (c *ClaudeExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (c *ClaudeExecutor) SupportsDangerousMode() bool

+ func (c *ClaudeExecutor) SupportsSessionResume() bool

+ func (c *ClaudeExecutor) Suspend(taskID int64) bool

+ type CodexExecutor struct

+ func NewCodexExecutor(e *Executor) *CodexExecutor

+ func (c *CodexExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (c *CodexExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (c *CodexExecutor) FindSessionID(workDir string) string

+ func (c *CodexExecutor) GetProcessID(taskID int64) int

+ func (c *CodexExecutor) IsAvailable() bool

+ func (c *CodexExecutor) IsSuspended(taskID int64) bool

+ func (c *CodexExecutor) Kill(taskID int64) bool

+ func (c *CodexExecutor) Name() string

+ func (c *CodexExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (c *CodexExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (c *CodexExecutor) ResumeProcess(taskID int64) bool

+ func (c *CodexExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (c *CodexExecutor) SupportsDangerousMode() bool

+ func (c *CodexExecutor) SupportsSessionResume() bool

+ func (c *CodexExecutor) Suspend(taskID int64) bool

+ type ExecResult struct

+ Interrupted bool

+ Message string

+ NeedsInput bool

+ Success bool

+ type Executor struct

+ func New(database *db.DB, cfg *config.Config) *Executor

+ func NewWithLogging(database *db.DB, cfg *config.Config, w io.Writer) *Executor

+ func (e *Executor) AllExecutors() []string

+ func (e *Executor) ArchiveWorktree(task *db.Task) error

+ func (e *Executor) AvailableExecutors() []string

+ func (e *Executor) CleanupDuplicateWindows(taskID int64)

+ func (e *Executor) CleanupStaleWorktreesManual(maxAge time.Duration, dryRun bool) ([]*db.Task, error)

+ func (e *Executor) CleanupWorktree(task *db.Task) error

+ func (e *Executor) DisplayName() string

+ func (e *Executor) ExecuteNow(ctx context.Context, taskID int64) error

+ func (e *Executor) ExecutorSlug() string

+ func (e *Executor) GetExecutor(name string) TaskExecutor

+ func (e *Executor) GetProjectDir(project string) string

+ func (e *Executor) GetTaskExecutor(task *db.Task) TaskExecutor

+ func (e *Executor) Interrupt(taskID int64) bool

+ func (e *Executor) IsClaudeRunning(taskID int64) bool

+ func (e *Executor) IsRunning(taskID int64) bool

+ func (e *Executor) IsSuspended(taskID int64) bool

+ func (e *Executor) KillClaudeProcess(taskID int64) bool

+ func (e *Executor) KillPiProcess(taskID int64) bool

+ func (e *Executor) NotifyTaskChange(eventType string, task *db.Task)

+ func (e *Executor) RenameClaudeSessionForTask(task *db.Task, newName string)

+ func (e *Executor) ResumeDangerous(taskID int64) bool

+ func (e *Executor) ResumeSafe(taskID int64) bool

+ func (e *Executor) ResumeTask(taskID int64) bool

+ func (e *Executor) RunningTasks() []int64

+ func (e *Executor) Start(ctx context.Context)

+ func (e *Executor) Stop()

+ func (e *Executor) Subscribe(taskID int64) chan *db.TaskLog

+ func (e *Executor) SubscribeTaskEvents() chan TaskEvent

+ func (e *Executor) SuspendTask(taskID int64) bool

+ func (e *Executor) TriggerProcessing()

+ func (e *Executor) UnarchiveWorktree(task *db.Task) error

+ func (e *Executor) Unsubscribe(taskID int64, ch chan *db.TaskLog)

+ func (e *Executor) UnsubscribeTaskEvents(ch chan TaskEvent)

+ type ExecutorFactory struct

+ func NewExecutorFactory() *ExecutorFactory

+ func (f *ExecutorFactory) All() []string

+ func (f *ExecutorFactory) Available() []string

+ func (f *ExecutorFactory) Get(name string) TaskExecutor

+ func (f *ExecutorFactory) Register(executor TaskExecutor)

+ type GeminiExecutor struct

+ func NewGeminiExecutor(e *Executor) *GeminiExecutor

+ func (g *GeminiExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (g *GeminiExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (g *GeminiExecutor) FindSessionID(workDir string) string

+ func (g *GeminiExecutor) GetProcessID(taskID int64) int

+ func (g *GeminiExecutor) IsAvailable() bool

+ func (g *GeminiExecutor) IsSuspended(taskID int64) bool

+ func (g *GeminiExecutor) Kill(taskID int64) bool

+ func (g *GeminiExecutor) Name() string

+ func (g *GeminiExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (g *GeminiExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (g *GeminiExecutor) ResumeProcess(taskID int64) bool

+ func (g *GeminiExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (g *GeminiExecutor) SupportsDangerousMode() bool

+ func (g *GeminiExecutor) SupportsSessionResume() bool

+ func (g *GeminiExecutor) Suspend(taskID int64) bool

+ type OpenClawExecutor struct

+ func NewOpenClawExecutor(e *Executor) *OpenClawExecutor

+ func (o *OpenClawExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (o *OpenClawExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (o *OpenClawExecutor) FindSessionID(workDir string) string

+ func (o *OpenClawExecutor) GetProcessID(taskID int64) int

+ func (o *OpenClawExecutor) IsAvailable() bool

+ func (o *OpenClawExecutor) IsSuspended(taskID int64) bool

+ func (o *OpenClawExecutor) Kill(taskID int64) bool

+ func (o *OpenClawExecutor) Name() string

+ func (o *OpenClawExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (o *OpenClawExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (o *OpenClawExecutor) ResumeProcess(taskID int64) bool

+ func (o *OpenClawExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (o *OpenClawExecutor) SupportsDangerousMode() bool

+ func (o *OpenClawExecutor) SupportsSessionResume() bool

+ func (o *OpenClawExecutor) Suspend(taskID int64) bool

+ type OpenCodeExecutor struct

+ func NewOpenCodeExecutor(e *Executor) *OpenCodeExecutor

+ func (o *OpenCodeExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (o *OpenCodeExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (o *OpenCodeExecutor) FindSessionID(workDir string) string

+ func (o *OpenCodeExecutor) GetProcessID(taskID int64) int

+ func (o *OpenCodeExecutor) IsAvailable() bool

+ func (o *OpenCodeExecutor) IsSuspended(taskID int64) bool

+ func (o *OpenCodeExecutor) Kill(taskID int64) bool

+ func (o *OpenCodeExecutor) Name() string

+ func (o *OpenCodeExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (o *OpenCodeExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (o *OpenCodeExecutor) ResumeProcess(taskID int64) bool

+ func (o *OpenCodeExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (o *OpenCodeExecutor) SupportsDangerousMode() bool

+ func (o *OpenCodeExecutor) SupportsSessionResume() bool

+ func (o *OpenCodeExecutor) Suspend(taskID int64) bool

+ type PiExecutor struct

+ func NewPiExecutor(e *Executor) *PiExecutor

+ func (p *PiExecutor) BuildCommand(task *db.Task, sessionID, prompt string) string

+ func (p *PiExecutor) Execute(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ func (p *PiExecutor) FindSessionID(workDir string) string

+ func (p *PiExecutor) GetProcessID(taskID int64) int

+ func (p *PiExecutor) IsAvailable() bool

+ func (p *PiExecutor) IsSuspended(taskID int64) bool

+ func (p *PiExecutor) Kill(taskID int64) bool

+ func (p *PiExecutor) Name() string

+ func (p *PiExecutor) Resume(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ func (p *PiExecutor) ResumeDangerous(task *db.Task, workDir string) bool

+ func (p *PiExecutor) ResumeSafe(task *db.Task, workDir string) bool

+ func (p *PiExecutor) SupportsDangerousMode() bool

+ func (p *PiExecutor) SupportsSessionResume() bool

+ func (p *PiExecutor) Suspend(taskID int64) bool

+ type ProjectConfig struct

+ Worktree WorktreeConfig

+ func LoadProjectConfig(projectDir string) (*ProjectConfig, error)

+ type TaskEvent struct

+ Task *db.Task

+ TaskID int64

+ Type string

+ type TaskExecutor interface

+ BuildCommand func(task *db.Task, sessionID, prompt string) string

+ Execute func(ctx context.Context, task *db.Task, workDir, prompt string) ExecResult

+ FindSessionID func(workDir string) string

+ GetProcessID func(taskID int64) int

+ IsAvailable func() bool

+ IsSuspended func(taskID int64) bool

+ Kill func(taskID int64) bool

+ Name func() string

+ Resume func(ctx context.Context, task *db.Task, workDir, prompt, feedback string) ExecResult

+ ResumeDangerous func(task *db.Task, workDir string) bool

+ ResumeSafe func(task *db.Task, workDir string) bool

+ SupportsDangerousMode func() bool

+ SupportsSessionResume func() bool

+ Suspend func(taskID int64) bool

+ type WorktreeConfig struct

+ InitScript string

+ TeardownScript string