api

package

Go to main page

Versions in this module

v0

v0.0.9

Jul 7, 2026

v0.0.8

Jul 3, 2026

Changes in this version

type MetaStore

+ GetWithWorkspace func(ctx context.Context, projectID string) (*orchestrator.ProjectMeta, error)

type ProjectAppService

+ Hydrator orchestrator.MetaHydrator

v0.0.7

Jun 25, 2026

Changes in this version

+ const AttachmentMaxFileBytes

+ const AttachmentMaxNameBytes

+ const AttachmentMaxTotalBytes

+ var AttachmentAllowedExts = map[string]bool

+ func AttachmentsRootForTask(dataHome, taskID string) string

+ func EnsureAttachmentsDir(dataHome, taskID string) (string, error)

+ func SanitizeAttachmentName(raw string) (string, error)

+ func SaveMultipartAttachments(dataHome, taskID string, files []*multipart.FileHeader) ([]string, error)

+ func ValidateAttachmentHeaders(files []*multipart.FileHeader) error

type TaskAppService

+ AskDisconnectGrace time.Duration

type WebHandler

+ AttachmentsRoot string

v0.0.6

Jun 22, 2026

Changes in this version

+ var ErrAskPending = errors.New("task_ask: another question is pending")

+ type BlockingAskRegistry struct

+ func NewBlockingAskRegistry() *BlockingAskRegistry

+ func (r *BlockingAskRegistry) Cancel(qid string)

+ func (r *BlockingAskRegistry) Has(qid string) bool

+ func (r *BlockingAskRegistry) Notify(qid, answer string) bool

+ func (r *BlockingAskRegistry) Register(taskID, qid string) error

+ func (r *BlockingAskRegistry) Wait(ctx context.Context, qid string) (string, error)

type CreateTaskRequest

+ Readonly *bool

type ProjectHandler

+ SessionDispatcher SessionDispatcher

+ func (h *ProjectHandler) StartSession(w http.ResponseWriter, r *http.Request)

+ type SessionDispatcher interface

+ StartSession func(ctx context.Context, req StartSessionRequest) (*StartSessionResult, error)

+ type SessionHandler struct

+ Dispatcher SessionDispatcher

+ Service ProjectService

+ func (h *SessionHandler) Routes() chi.Router

+ func (h *SessionHandler) Start(w http.ResponseWriter, r *http.Request)

+ type StartSessionRequest struct

+ DisplayName string

+ HarnessType string

+ Instruction string

+ Model string

+ ProjectID string

+ Readonly bool

+ type StartSessionResult struct

+ AttachURL string

+ JobID string

type TaskAppService

+ BlockingAsk *BlockingAskRegistry

+ func (s *TaskAppService) AskTaskBlocking(ctx context.Context, taskID, question string) (string, error)

type TaskStore

+ ListChildren func(parentID string) ([]*orchestrator.Task, error)

type TaskWorkflowService

+ Adapter adapters.HarnessAdapter

type WebHandler

+ SessionDispatcher SessionDispatcher

+ func (h *WebHandler) PostStartSession(w http.ResponseWriter, r *http.Request)

type WorktreeCleaner

+ SweepChildBranches func(projectDir string, taskIDs []string) error

v0.0.5

Jun 15, 2026

v0.0.4

Jun 9, 2026

Changes in this version

type JobHandler

+ func (h *JobHandler) Patch(w http.ResponseWriter, r *http.Request)

+ type UpdateJobRequest struct

+ DisplayName *string

v0.0.3

Jun 5, 2026

v0.0.2

Jun 4, 2026

Changes in this version

type JobListFilter

+ TasklessOnly bool

type WebAppService

+ func (s *WebAppService) ListSessions() ([]JobWithContext, error)

type WebHandler

+ func (h *WebHandler) SessionList(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) SessionNew(w http.ResponseWriter, r *http.Request)

type WebService

+ ListSessions func() ([]JobWithContext, error)

v0.0.1

Jun 2, 2026

Changes in this version

+ func BuildFlatItems(tasks []*orchestrator.Task, projectNames map[string]string) []components.TreeItem

+ func BuildTreeItems(tasks []*orchestrator.Task, projectNames map[string]string) []components.TreeItem

+ func ResolveTaskField(task *orchestrator.Task, actions orchestrator.LifecycleStore, path string) (string, error)

+ type ActionApplication struct

+ Action *orchestrator.Action

+ MatchedHooks []string

+ Task *orchestrator.Task

+ type ActionHandler struct

+ Service WorkflowService

+ func (h *ActionHandler) Apply(w http.ResponseWriter, r *http.Request)

+ func (h *ActionHandler) Routes() chi.Router

+ type ActionStore interface

+ CreateAction func(action *orchestrator.Action) error

+ ListActionsByTask func(taskID string) ([]*orchestrator.Action, error)

+ type AnswerTaskRequest struct

+ Answer string

+ QuestionID string

+ type ApplyActionRequest struct

+ Payload json.RawMessage

+ Type string

+ type BrokerHandler struct

+ Registry BrokerRegistry

+ func (h *BrokerHandler) Register(w http.ResponseWriter, r *http.Request)

+ func (h *BrokerHandler) Routes() chi.Router

+ type BrokerRegisterRequest struct

+ BuiltinPolicies map[string]sandbox.BuiltinPolicy

+ Commands map[string]orchestrator.HostCommandSpec

+ ProjectID string

+ type BrokerRegisterResponse struct

+ ResolvedHostCommands map[string]orchestrator.CommandDef

+ Socket string

+ Token string

+ type BrokerRegistry interface

+ RegisterBrokerCommands func(commands map[string]orchestrator.HostCommandSpec, ...) (*BrokerRegisterResponse, error)

+ type CommandDispatcher interface

+ ExecuteCommand func(ctx context.Context, projectID, commandName string) (*ExecuteCommandResult, error)

+ type CommandResponse struct

+ AdditionalBindings []orchestrator.BindMount

+ Command []string

+ Env map[string]string

+ HostCommands map[string]orchestrator.HostCommandSpec

+ Readonly bool

+ type CommandSummary struct

+ Command []string

+ Name string

+ Readonly bool

+ type CreateProjectRequest struct

+ WorkDir string

+ type CreateTaskRequest struct

+ AutoStart bool

+ Behavior string

+ BehaviorSpec *orchestrator.BehaviorSpec

+ Description string

+ ID string

+ Instructions json.RawMessage

+ ParentID string

+ Payload json.RawMessage

+ ProjectID string

+ Ref string

+ RemoteID string

+ Title string

+ Traits []string

+ type DeviceGCStore interface

+ DeleteRevokedDevices func(ctx context.Context, dryRun bool) (int64, error)

+ type DispatchCoordinator interface

+ DispatchAndAdvance func(ctx context.Context, task *orchestrator.Task, meta *orchestrator.ProjectMeta, ...) (*orchestrator.DispatchResult, error)

+ ReplayHook func(ctx context.Context, task *orchestrator.Task, meta *orchestrator.ProjectMeta, ...) (*orchestrator.ReplayResult, error)

+ type DuplicateTaskRequest struct

+ AutoStart bool

+ type ExecuteCommandResult struct

+ AttachURL string

+ JobID string

+ type GCAppService struct

+ DeviceStore DeviceGCStore

+ Store GCStore

+ func (s *GCAppService) GC(olderThan time.Duration, dryRun bool) (*orchestrator.GCResult, error)

+ func (s *GCAppService) Run(olderThan time.Duration, dryRun bool) (*orchestrator.GCResult, error)

+ type GCHandler struct

+ Service GCService

+ func (h *GCHandler) Routes() chi.Router

+ func (h *GCHandler) Run(w http.ResponseWriter, r *http.Request)

+ type GCService interface

+ Run func(olderThan time.Duration, dryRun bool) (*orchestrator.GCResult, error)

+ type GCStore interface

+ GC func(olderThan time.Duration, dryRun bool) (*orchestrator.GCResult, error)

+ type GlobalJobStore interface

+ ListJobsWithContext func(filter JobListFilter) ([]JobWithContext, error)

+ type HookService interface

+ ListHooksForStatus func(taskID, status string) ([]orchestrator.Hook, error)

+ ReplayHook func(ctx context.Context, taskID string, req ReplayHookRequest) (*ReplayHookResult, error)

+ type ImportError struct

+ Error string

+ Line int

+ RemoteID string

+ type ImportResult struct

+ Created int

+ Errors []ImportError

+ Skipped int

+ type Job struct

+ CreatedAt time.Time

+ DisplayName string

+ ExecutionState string

+ ExitCode int

+ HandlerID string

+ ID string

+ Interactive bool

+ Output string

+ ProjectID string

+ Role string

+ RuntimeID string

+ Status JobStatus

+ TTY bool

+ TaskID string

+ TranscriptIdleSeconds int64

+ TranscriptMtime *time.Time

+ TranscriptSize int64

+ UpdatedAt time.Time

+ WorkspacePath string

+ type JobCompletion struct

+ ExitCode int

+ Output string

+ type JobDoneRequest struct

+ ExitCode int

+ Output string

+ type JobHandler struct

+ Global GlobalJobStore

+ Jobs JobStore

+ LogReader JobLogReader

+ SSEHandler http.Handler

+ Service WorkflowService

+ func (h *JobHandler) AgentStop(w http.ResponseWriter, r *http.Request)

+ func (h *JobHandler) Done(w http.ResponseWriter, r *http.Request)

+ func (h *JobHandler) Get(w http.ResponseWriter, r *http.Request)

+ func (h *JobHandler) List(w http.ResponseWriter, r *http.Request)

+ func (h *JobHandler) Log(w http.ResponseWriter, r *http.Request)

+ func (h *JobHandler) Routes() chi.Router

+ type JobLifecycle interface

+ CleanupTaskWindow func(taskID string)

+ CompleteJob func(jobID string, result JobCompletion)

+ SignalJobRuntime func(runtimeID string, sig syscall.Signal)

+ StopJobRuntime func(runtimeID string)

+ UnregisterJob func(jobID string)

+ type JobListFilter struct

+ Interactive *bool

+ Status string

+ type JobLogReader interface

+ ReadJobLog func(runtimeID string) ([]byte, error)

+ StatJobLog func(runtimeID string) (size int64, mtime time.Time, err error)

+ type JobLogSSEHandler struct

+ Registry *auth.ConnectionRegistry

+ Subscriber dispatcher.RuntimeSubscriber

+ func (h *JobLogSSEHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type JobStatus string

+ const JobStatusCompleted

+ const JobStatusFailed

+ const JobStatusRunning

+ type JobStore interface

+ GetJob func(id string) (*Job, error)

+ ListJobsByTask func(taskID string) ([]*Job, error)

+ UpdateJob func(job *Job) error

+ type JobWithContext struct

+ ProjectName string

+ TaskTitle string

+ type LoginHandler struct

+ Limiter loginRateLimiter

+ Pairing loginPairing

+ Signer loginSigner

+ Store loginDeviceStore

+ func (h *LoginHandler) GetAuth(w http.ResponseWriter, r *http.Request)

+ func (h *LoginHandler) GetLogin(w http.ResponseWriter, r *http.Request)

+ func (h *LoginHandler) PostLogin(w http.ResponseWriter, r *http.Request)

+ type MetaStore interface

+ Get func(id string) (*orchestrator.ProjectMeta, bool)

+ type Notifier interface

+ Notify func(ctx context.Context, ev notify.Event) error

+ type NotifyTaskRequest struct

+ Ask string

+ Done string

+ Fail string

+ Message string

+ Progress string

+ QuestionID string

+ SessionID string

+ type Pairer interface

+ Issue func(ctx context.Context, label string) (string, error)

+ type ProjectAppService struct

+ Meta interface{ ... }

+ Projects ProjectRepository

+ func (s *ProjectAppService) CreateProject(workDir string) (*orchestrator.Project, error)

+ func (s *ProjectAppService) DeleteProject(id string) error

+ func (s *ProjectAppService) GetCommand(id, name string) (*CommandResponse, error)

+ func (s *ProjectAppService) GetProject(id string) (*orchestrator.Project, error)

+ func (s *ProjectAppService) ListCommands(id string) ([]CommandSummary, error)

+ func (s *ProjectAppService) ListProjects(workspaceID string) ([]*orchestrator.Project, error)

+ func (s *ProjectAppService) ListWorkspaces() ([]*orchestrator.WorkspaceSummary, error)

+ func (s *ProjectAppService) ReloadProjects() (*ProjectReloadResult, error)

+ func (s *ProjectAppService) ResolveProjectRef(ref string) ([]*orchestrator.Project, error)

+ func (s *ProjectAppService) SetProjectWorkspace(id, workspaceID string) (*orchestrator.Project, error)

+ type ProjectHandler struct

+ Dispatcher CommandDispatcher

+ Service ProjectService

+ func (h *ProjectHandler) Create(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) Delete(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) ExecuteCommand(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) Get(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) GetCommand(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) List(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) ListCommands(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) Reload(w http.ResponseWriter, r *http.Request)

+ func (h *ProjectHandler) Routes() chi.Router

+ func (h *ProjectHandler) SetWorkspace(w http.ResponseWriter, r *http.Request)

+ type ProjectReloadResult struct

+ Errors []string

+ Status string

+ type ProjectRepository interface

+ CreateProject func(project *orchestrator.Project) error

+ DeleteProject func(id string) error

+ GetProject func(id string) (*orchestrator.Project, error)

+ ListProjects func() ([]*orchestrator.Project, error)

+ ListWorkspaces func() ([]*orchestrator.WorkspaceSummary, error)

+ SetProjectWorkspace func(projectID, workspaceID string) error

+ type ProjectService interface

+ CreateProject func(workDir string) (*orchestrator.Project, error)

+ DeleteProject func(id string) error

+ GetCommand func(id, name string) (*CommandResponse, error)

+ GetProject func(id string) (*orchestrator.Project, error)

+ ListCommands func(id string) ([]CommandSummary, error)

+ ListProjects func(workspaceID string) ([]*orchestrator.Project, error)

+ ListWorkspaces func() ([]*orchestrator.WorkspaceSummary, error)

+ ReloadProjects func() (*ProjectReloadResult, error)

+ ResolveProjectRef func(ref string) ([]*orchestrator.Project, error)

+ SetProjectWorkspace func(id, workspaceID string) (*orchestrator.Project, error)

+ type ProjectWorkDirLookup interface

+ GetProject func(id string) (*orchestrator.Project, error)

+ type ReopenTaskRequest struct

+ Message string

+ type ReplayHookRequest struct

+ HookID string

+ Status string

+ type ReplayHookResult struct

+ FiredEvents []orchestrator.FiredEvent

+ Task *orchestrator.Task

+ type RerunTaskRequest struct

+ AutoStart bool

+ InstructionsOverride json.RawMessage

+ type SecretHandler struct

+ Store SecretStore

+ func (h *SecretHandler) Delete(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandler) GetValue(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandler) List(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandler) Routes() chi.Router

+ func (h *SecretHandler) Set(w http.ResponseWriter, r *http.Request)

+ type SecretStore interface

+ Delete func(namespace, key string) error

+ Get func(namespace, key string) (string, error)

+ List func(namespace string) ([]string, error)

+ Set func(namespace, key, value string) error

+ type SetProjectWorkspaceRequest struct

+ WorkspaceID string

+ type StatusError struct

+ Code int

+ Message string

+ func (e *StatusError) Error() string

+ type TaskAnswerService interface

+ AnswerTask func(ctx context.Context, taskID, questionID, answer string) error

+ type TaskAppService struct

+ Actions ActionStore

+ Jobs JobStore

+ Meta MetaStore

+ Notify Notifier

+ Projects ProjectWorkDirLookup

+ RuntimesDir string

+ Tasks TaskStore

+ Workflow WorkflowService

+ func (s *TaskAppService) AnswerTask(ctx context.Context, taskID, questionID, answer string) error

+ func (s *TaskAppService) CreateTask(req CreateTaskRequest) (*orchestrator.Task, error)

+ func (s *TaskAppService) DeleteTask(id string, force bool) error

+ func (s *TaskAppService) DuplicateTask(sourceID string, autoStart bool) (*orchestrator.Task, error)

+ func (s *TaskAppService) GetTask(id string) (*orchestrator.Task, error)

+ func (s *TaskAppService) GetTaskBehaviorCommand(taskID, name string) (*CommandResponse, error)

+ func (s *TaskAppService) GetTaskDetail(id string) (*TaskDetailView, error)

+ func (s *TaskAppService) GetTaskField(id, path string) (string, error)

+ func (s *TaskAppService) ImportTasks(reqs []CreateTaskRequest) (*ImportResult, error)

+ func (s *TaskAppService) ListTaskBehaviorCommands(taskID string) ([]CommandSummary, error)

+ func (s *TaskAppService) ListTasks(filter orchestrator.TaskFilter) ([]*orchestrator.Task, error)

+ func (s *TaskAppService) NotifyTask(ctx context.Context, ...) error

+ func (s *TaskAppService) RerunTask(id string, req RerunTaskRequest) (*orchestrator.Task, error)

+ func (s *TaskAppService) UpdateTask(id string, req UpdateTaskRequest) (*orchestrator.Task, error)

+ type TaskCommandDispatcher interface

+ ExecuteTaskBehaviorCommand func(ctx context.Context, taskID, commandName string) (*ExecuteCommandResult, error)

+ ListTaskBehaviorCommands func(taskID string) ([]CommandSummary, error)

+ type TaskDetailView struct

+ Actions []*orchestrator.Action

+ AvailableActions []string

+ Dependents []*orchestrator.Task

+ Jobs []*Job

+ Task *orchestrator.Task

+ type TaskEvent struct

+ Kind string

+ Payload any

+ type TaskEventHub struct

+ func NewTaskEventHub() *TaskEventHub

+ func (h *TaskEventHub) Broadcast(taskID string, ev TaskEvent)

+ func (h *TaskEventHub) Subscribe(ctx context.Context, taskID string) <-chan TaskEvent

+ type TaskHandler struct

+ Answerer TaskAnswerService

+ Dispatcher TaskCommandDispatcher

+ Hooks HookService

+ Notifier TaskNotifyService

+ Service TaskService

+ func (h *TaskHandler) Answer(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Create(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Delete(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Detail(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Duplicate(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) ExecuteTaskCommand(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Field(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Get(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Import(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) List(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) ListHooks(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) ListTaskCommands(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Notify(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Patch(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) ReplayHook(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Rerun(w http.ResponseWriter, r *http.Request)

+ func (h *TaskHandler) Routes() chi.Router

+ type TaskNotifyService interface

+ NotifyTask func(ctx context.Context, ...) error

+ type TaskService interface

+ CreateTask func(req CreateTaskRequest) (*orchestrator.Task, error)

+ DeleteTask func(id string, force bool) error

+ DuplicateTask func(sourceID string, autoStart bool) (*orchestrator.Task, error)

+ GetTask func(id string) (*orchestrator.Task, error)

+ GetTaskDetail func(id string) (*TaskDetailView, error)

+ GetTaskField func(id, path string) (string, error)

+ ImportTasks func(reqs []CreateTaskRequest) (*ImportResult, error)

+ ListTasks func(filter orchestrator.TaskFilter) ([]*orchestrator.Task, error)

+ RerunTask func(id string, req RerunTaskRequest) (*orchestrator.Task, error)

+ UpdateTask func(id string, req UpdateTaskRequest) (*orchestrator.Task, error)

+ type TaskStore interface

+ CreateTask func(task *orchestrator.Task) error

+ DeleteTask func(id string) error

+ FindDependentTasks func(taskID string) ([]*orchestrator.Task, error)

+ FindTaskByRef func(ref, parentID string) (*orchestrator.Task, error)

+ FindTaskByRemote func(remoteID string) (*orchestrator.Task, error)

+ GetTask func(id string) (*orchestrator.Task, error)

+ ListTasks func(filter orchestrator.TaskFilter) ([]*orchestrator.Task, error)

+ UpdateTask func(task *orchestrator.Task) error

+ type TaskWorkflowService struct

+ Coordinator DispatchCoordinator

+ Hub *TaskEventHub

+ Jobs JobStore

+ Lifecycle JobLifecycle

+ Locks *orchestrator.BranchLockManager

+ Meta MetaStore

+ Projects ProjectRepository

+ Tasks TaskStore

+ Tx Transactor

+ Worktrees WorktreeCleaner

+ func (s *TaskWorkflowService) ApplyAction(ctx context.Context, taskID string, req ApplyActionRequest) (*ActionApplication, error)

+ func (s *TaskWorkflowService) CompleteJob(_ context.Context, jobID string, req JobDoneRequest) (*Job, error)

+ func (s *TaskWorkflowService) InitDispatch(ctx context.Context)

+ func (s *TaskWorkflowService) ListHooksForStatus(taskID, status string) ([]orchestrator.Hook, error)

+ func (s *TaskWorkflowService) ReplayHook(ctx context.Context, taskID string, req ReplayHookRequest) (*ReplayHookResult, error)

+ func (s *TaskWorkflowService) Shutdown()

+ func (s *TaskWorkflowService) StopAgent(runtimeID string)

+ func (s *TaskWorkflowService) TriggerDependents(ctx context.Context, taskID string)

+ type Transactor interface

+ WithinTx func(func(TxStore) error) error

+ type TxStore interface

+ type UpdateTaskRequest struct

+ AutoStart *bool

+ Description string

+ Instructions json.RawMessage

+ ParentID *string

+ Payload json.RawMessage

+ ProjectID string

+ RemoteID *string

+ Title string

+ type WSAttachHandler struct — linux/amd64

+ PublicURL string

+ Registry *auth.ConnectionRegistry

+ Subscriber dispatcher.RuntimeSubscriber

+ Writer dispatcher.RuntimeInputWriter

+ func (h *WSAttachHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WebAppService struct

+ Actions ActionStore

+ Answerer TaskAnswerService

+ GlobalJobs GlobalJobStore

+ Hooks HookService

+ Jobs JobStore

+ Meta MetaStore

+ Projects ProjectRepository

+ TaskSvc TaskService

+ Tasks TaskStore

+ Workflow WorkflowService

+ func (s *WebAppService) AnswerTask(ctx context.Context, taskID, questionID, answer string) error

+ func (s *WebAppService) ApplyAction(taskID string, actionType string) error

+ func (s *WebAppService) CreateTask(req CreateTaskRequest) (*orchestrator.Task, error)

+ func (s *WebAppService) DeleteTask(id string, force bool) error

+ func (s *WebAppService) DuplicateTask(id string) (string, error)

+ func (s *WebAppService) GetJob(id string) (*JobWithContext, error)

+ func (s *WebAppService) GetProjectByID(id string) (*orchestrator.Project, error)

+ func (s *WebAppService) GetTaskDetail(id string) (*TaskDetailView, error)

+ func (s *WebAppService) ListBehaviors() ([]string, error)

+ func (s *WebAppService) ListHooksForStatus(taskID, status string) ([]orchestrator.Hook, error)

+ func (s *WebAppService) ListJobs(status string) ([]JobWithContext, error)

+ func (s *WebAppService) ListProjectCommands(projectID string) ([]CommandSummary, error)

+ func (s *WebAppService) ListProjects() ([]*orchestrator.Project, error)

+ func (s *WebAppService) ListTaskBehaviorCommands(taskID string) ([]CommandSummary, error)

+ func (s *WebAppService) ListTasks(filter orchestrator.TaskFilter) ([]*orchestrator.Task, error)

+ func (s *WebAppService) ListWorkspaces() ([]*orchestrator.WorkspaceSummary, error)

+ func (s *WebAppService) ReopenTask(id string, req ReopenTaskRequest) error

+ func (s *WebAppService) ReplayHook(ctx context.Context, taskID string, req ReplayHookRequest) (*ReplayHookResult, error)

+ func (s *WebAppService) RerunTask(id string, req RerunTaskRequest) error

+ func (s *WebAppService) UpdateTask(id string, req UpdateTaskRequest) error

+ type WebHandler struct

+ Dispatcher CommandDispatcher

+ Hub *TaskEventHub

+ Registry *auth.ConnectionRegistry

+ Service WebService

+ TaskDispatcher TaskCommandDispatcher

+ func (h *WebHandler) GetTaskEdit(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) HookReplayList(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) JobDetail(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) JobTerminal(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostAction(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostAnswer(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostDelete(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostDuplicate(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostEdit(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostHookReplay(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostProjectExecuteCommand(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostReopen(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostRerun(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostTaskCreate(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) PostTaskExecuteCommand(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) ProjectCommandList(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) QuestionPage(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) ReopenForm(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) Routes() chi.Router

+ func (h *WebHandler) TaskDetail(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) TaskDetailFragment(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) TaskEvents(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) TaskList(w http.ResponseWriter, r *http.Request)

+ func (h *WebHandler) TaskNew(w http.ResponseWriter, r *http.Request)

+ type WebManagementHandler struct

+ Pairing Pairer

+ PublicURL string

+ Registry *auth.ConnectionRegistry

+ Store *auth.Store

+ func (h *WebManagementHandler) DeleteAllDevices(w http.ResponseWriter, r *http.Request)

+ func (h *WebManagementHandler) DeleteDevice(w http.ResponseWriter, r *http.Request)

+ func (h *WebManagementHandler) GetDevices(w http.ResponseWriter, r *http.Request)

+ func (h *WebManagementHandler) PostPair(w http.ResponseWriter, r *http.Request)

+ func (h *WebManagementHandler) Routes() chi.Router

+ type WebService interface

+ AnswerTask func(ctx context.Context, taskID, questionID, answer string) error

+ ApplyAction func(taskID string, actionType string) error

+ CreateTask func(req CreateTaskRequest) (*orchestrator.Task, error)

+ DeleteTask func(id string, force bool) error

+ DuplicateTask func(id string) (string, error)

+ GetJob func(id string) (*JobWithContext, error)

+ GetProjectByID func(id string) (*orchestrator.Project, error)

+ GetTaskDetail func(id string) (*TaskDetailView, error)

+ ListBehaviors func() ([]string, error)

+ ListHooksForStatus func(taskID, status string) ([]orchestrator.Hook, error)

+ ListJobs func(status string) ([]JobWithContext, error)

+ ListProjectCommands func(projectID string) ([]CommandSummary, error)

+ ListProjects func() ([]*orchestrator.Project, error)

+ ListTaskBehaviorCommands func(taskID string) ([]CommandSummary, error)

+ ListTasks func(filter orchestrator.TaskFilter) ([]*orchestrator.Task, error)

+ ListWorkspaces func() ([]*orchestrator.WorkspaceSummary, error)

+ ReopenTask func(id string, req ReopenTaskRequest) error

+ ReplayHook func(ctx context.Context, taskID string, req ReplayHookRequest) (*ReplayHookResult, error)

+ RerunTask func(id string, req RerunTaskRequest) error

+ UpdateTask func(id string, req UpdateTaskRequest) error

+ type WorkflowService interface

+ ApplyAction func(ctx context.Context, taskID string, req ApplyActionRequest) (*ActionApplication, error)

+ CompleteJob func(ctx context.Context, jobID string, req JobDoneRequest) (*Job, error)

+ StopAgent func(runtimeID string)

+ TriggerDependents func(ctx context.Context, taskID string)

+ type WorkspaceHandler struct

+ Service ProjectService

+ func (h *WorkspaceHandler) List(w http.ResponseWriter, r *http.Request)

+ func (h *WorkspaceHandler) Routes() chi.Router

+ type WorktreeCleaner interface

+ CleanupForTask func(taskID, projectDir, newStatus string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL