tools

package

Go to main page

Versions in this module

v0

v0.11.2

Jul 23, 2026

Changes in this version

type FlowSpawnDeps

+ AgentRoles map[string]config.AgentRoleConfig

type SubagentDeps

+ AgentRoles map[string]config.AgentRoleConfig

type WorkflowToolDeps

+ AgentRoles map[string]config.AgentRoleConfig

v0.11.1

Jul 22, 2026

v0.10.1

Jul 19, 2026

Changes in this version

+ func IsReadOnlyShellCommand(command string) bool

+ func MCPDisplayNameForTool(toolName string) (string, bool)

+ func MCPOriginalToolName(toolName string) (string, bool)

+ func RegisterMCPToolIdentity(canonicalName, serverName, originalName string)

type Env

+ Computer *computer.Manager

+ func (e *Env) CloseComputer()

+ func (e *Env) ComputerSession(ctx context.Context) (*computer.Session, error)

+ func (e *Env) CurrentComputerApp() string

+ func (e *Env) NewComputerPlanTools() []tool.BaseTool

+ func (e *Env) NewComputerTools() []tool.BaseTool

+ func (e *Env) NewPlanExecuteTool() tool.InvokableTool

+ type MCPToolIdentity struct

+ CanonicalName string

+ DisplayName string

+ OriginalName string

+ ServerName string

+ func MCPToolIdentityForTool(toolName string) (MCPToolIdentity, bool)

v0.9.6

Jul 16, 2026

v0.9.5

Jul 14, 2026

v0.9.4

Jul 12, 2026

Changes in this version

+ func MCPServerForTool(toolName string) (string, bool)

+ func PresentationKindForTool(name, argsJSON string) (kind string, collapsible bool)

+ func RegisterMCPToolServer(toolName, serverName string)

type CommandCategory

+ func ClassifyCommand(cmd string) CommandCategory

+ type ExecMeta struct

+ DurationMs int64

+ ExitCode int

+ SpillPath string

+ TimedOut bool

+ Truncated bool

+ type ExecPresentation struct

+ Collapsible bool

+ Kind string

+ Subtitle string

+ Title string

+ type ExecResult struct

+ DisplayBody string

+ Meta ExecMeta

+ ModelOutput string

+ Presentation ExecPresentation

+ Streams ExecStreams

+ func BuildExecResult(stdout, stderr string, runErr error, elapsed time.Duration, command string) ExecResult

+ func ParseExecModelOutput(output string) (ExecResult, bool)

+ type ExecStreams struct

+ Aggregated string

+ Stderr string

+ Stdout string

v0.9.3

Jul 6, 2026

v0.9.2

Jul 6, 2026

Changes in this version

+ func Fatal(err error) error

+ func IsFatal(err error) bool

type BgNotification

+ LogPath string

type BgTask

+ LogPath string

type ConflictStatus

+ const ConflictNeverRead

type EditOp

+ ReplaceAll bool

+ type ExternalChange struct

+ Gone bool

+ Path string

type FileTracker

+ func (ft *FileTracker) ScanExternalChanges(limit int) []ExternalChange

type TaskLog

+ func (tl *TaskLog) Path() string

+ type ToolError struct

+ Code string

+ Err error

+ Hint string

+ func (e *ToolError) Error() string

+ func (e *ToolError) Unwrap() error

v0.9.1

Jul 5, 2026

Changes in this version

+ func NewFlowSpawn(deps FlowSpawnDeps) flow.SpawnFunc

type Env

+ func (e *Env) NewWorkflowRunTool(deps *WorkflowToolDeps) tool.InvokableTool

+ type FlowSpawnDeps struct

+ Env *Env

+ ModelFactory *internalmodel.ModelFactory

+ Recorder *session.Recorder

+ Tracer *telemetry.LangfuseTracer

+ type WorkflowToolDeps struct

+ Loader *flow.Loader

+ ModelFactory *internalmodel.ModelFactory

+ Recorder *session.Recorder

+ Sink flow.EventSink

+ Tracer *telemetry.LangfuseTracer

v0.8.1

Jul 5, 2026

Changes in this version

type Env

+ Browser *browser.Manager

+ func (e *Env) BrowserSession(ctx context.Context) (*browser.Session, error)

+ func (e *Env) CloseBrowser()

+ func (e *Env) CurrentBrowserOrigin() string

+ func (e *Env) NewBrowserPlanTools() []tool.BaseTool

+ func (e *Env) NewBrowserTools() []tool.BaseTool

+ func (e *Env) NewMemoryNoteTool(deps *MemoryNoteDeps) tool.InvokableTool

+ type MemoryNoteDeps struct

+ SessionIDFn func() string

+ type MemoryNoteInput struct

+ Kind string

+ Scope string

+ Source string

+ Text string

v0.7.2

Jun 28, 2026

v0.7.1

Jun 24, 2026

Changes in this version

type Env

+ AutomationStore *automation.Store

+ func (e *Env) NewAutomationCreateTool() tool.InvokableTool

v0.6.4

Jun 23, 2026

Changes in this version

+ func DockerClient() (*client.Client, error)

+ type DockerExecutor struct

+ func AcquireDockerContainer(ctx context.Context, containerRef string) (*DockerExecutor, error)

+ func (d *DockerExecutor) Close() error

+ func (d *DockerExecutor) ContainerID() string

+ func (d *DockerExecutor) Exec(ctx context.Context, command, workDir string, timeout time.Duration) (string, string, error)

+ func (d *DockerExecutor) Label() string

+ func (d *DockerExecutor) MkdirAll(ctx context.Context, path string, _ os.FileMode) error

+ func (d *DockerExecutor) Name() string

+ func (d *DockerExecutor) Platform() string

+ func (d *DockerExecutor) ProjectLabel(pwd string) string

+ func (d *DockerExecutor) ReadFile(ctx context.Context, path string) ([]byte, error)

+ func (d *DockerExecutor) Stat(ctx context.Context, path string) (*FileInfo, error)

+ func (d *DockerExecutor) WriteFile(ctx context.Context, path string, data []byte, perm os.FileMode) error

type Env

+ func (e *Env) CloseRemote() error

+ func (e *Env) SetRemote(executor RemoteExecutor, remotePwd string)

+ type RemoteExecutor interface

+ Close func() error

+ ProjectLabel func(pwd string) string

type SSHExecutor

+ func (s *SSHExecutor) ProjectLabel(pwd string) string

v0.6.3

Jun 22, 2026

v0.6.2

Jun 21, 2026

v0.6.1

Jun 20, 2026

Changes in this version

type SSHExecutor

+ func (s *SSHExecutor) Host() string

+ func (s *SSHExecutor) User() string

v0.5.2

Jun 14, 2026

Changes in this version

+ var ErrOAuthNeedsClientID = errors.New("dynamic client registration unavailable; set an OAuth Client ID")

+ func DeleteMCPOAuthToken(serverName string) error

+ func HasMCPOAuthToken(serverName string) bool

+ func MCPOAuthDir() string

+ func NewMCPTokenStore(serverName string) transport.TokenStore

+ func PerformMCPOAuthLogin(ctx context.Context, name string, srv *config.MCPServer, ...) error

type AskUserDeps

+ BatchRequestFn func(ctx context.Context, questions []AskUserQuestion) (AskUserBatchResponse, error)

type MCPStatus

+ NeedsAuth bool

v0.5.1

Jun 13, 2026

v0.5.0

Jun 13, 2026

Changes in this version

+ func GoalKickoffPrompt(objective string) string

+ func GoalRecorderHook(rec *session.Recorder) func(*Goal)

+ func ValidateGoalObjective(objective string) (string, error)

type Env

+ GoalStore *GoalStore

+ func (e *Env) NewGoalGetTool() tool.InvokableTool

+ func (e *Env) NewGoalSetTool() tool.InvokableTool

+ func (e *Env) NewGoalUpdateTool() tool.InvokableTool

+ type Goal struct

+ CreatedAt int64

+ Objective string

+ Status GoalStatus

+ TokensUsed int64

+ UpdatedAt int64

+ type GoalCommand struct

+ Kind string

+ Objective string

+ func ParseGoalCommand(rest string) GoalCommand

+ type GoalStatus string

+ const GoalActive

+ const GoalBlocked

+ const GoalComplete

+ type GoalStore struct

+ OnUpdate func(g *Goal)

+ func NewGoalStore() *GoalStore

+ func (s *GoalStore) Block() bool

+ func (s *GoalStore) Clear()

+ func (s *GoalStore) Complete() bool

+ func (s *GoalStore) ContinuationPrompt() string

+ func (s *GoalStore) Get() *Goal

+ func (s *GoalStore) Has() bool

+ func (s *GoalStore) IsActive() bool

+ func (s *GoalStore) RecordTokens(cumulativeTotal int64)

+ func (s *GoalStore) Restore(g *Goal)

+ func (s *GoalStore) RestoreFromSnapshot(snap *session.GoalSnapshot)

+ func (s *GoalStore) Set(objective string) *Goal

+ func (s *GoalStore) StatusLine() string

v0.4.11

Jun 3, 2026

v0.4.10

Jun 2, 2026

v0.4.9

May 22, 2026

v0.4.8

May 22, 2026

v0.4.7

May 21, 2026

v0.4.6

May 14, 2026

v0.4.5

Apr 27, 2026

v0.4.4

Apr 27, 2026

v0.4.3

Apr 27, 2026

Changes in this version

+ type ACPExecutor struct

+ func NewACPExecutor(conn *acp.AgentSideConnection, sessionID acp.SessionId, platform string) *ACPExecutor

+ func (a *ACPExecutor) Exec(ctx context.Context, command, workDir string, timeout time.Duration) (string, string, error)

+ func (a *ACPExecutor) Label() string

+ func (a *ACPExecutor) MkdirAll(ctx context.Context, path string, perm os.FileMode) error

+ func (a *ACPExecutor) Platform() string

+ func (a *ACPExecutor) ReadFile(ctx context.Context, path string) ([]byte, error)

+ func (a *ACPExecutor) Stat(ctx context.Context, path string) (*FileInfo, error)

+ func (a *ACPExecutor) WriteFile(ctx context.Context, path string, data []byte, _ os.FileMode) error

type Env

+ func NewEnvWithExecutor(pwd, platform string, exec Executor) *Env

+ func (e *Env) IsACP() bool

+ func (e *Env) SetACP(executor *ACPExecutor, pwd string)

v0.4.2

Apr 26, 2026

v0.4.1

Apr 26, 2026

v0.3.10

Apr 25, 2026

v0.3.9

Apr 24, 2026

v0.3.8

Apr 24, 2026

v0.3.7

Apr 24, 2026

v0.3.6

Apr 23, 2026

v0.3.5

Apr 23, 2026

v0.3.4

Apr 21, 2026

v0.3.3

Apr 20, 2026

Changes in this version

type ExecuteInput

+ Description string

v0.3.2

Apr 19, 2026

v0.3.1

Apr 18, 2026

v0.2.2

Apr 17, 2026

v0.2.1

Apr 17, 2026

v0.1.1

Apr 16, 2026

v0.0.5

Apr 16, 2026

v0.0.4

Apr 15, 2026

Changes in this version

type SubagentDeps

+ Tracer *telemetry.LangfuseTracer

v0.0.3

Apr 15, 2026

v0.0.2

Apr 15, 2026

Changes in this version

+ const AgentTypeCoordinator

+ const AgentTypeExplore

+ const AgentTypeGeneral

+ const MaxEditFileSize

+ const MaxReadFileSize

+ const MaxSubagentDepth

+ const MaxWriteFileSize

+ const StatusCompleted

+ const StatusInProgress

+ const StatusNotStarted

+ const StatusSkipped

+ func BuildSSHAuthMethods() []ssh.AuthMethod

+ func NewAskUserTool(deps *AskUserDeps) tool.InvokableTool

+ func NewEnhancedTodoReadTool(store *EnhancedTodoStore) tool.InvokableTool

+ func NewEnhancedTodoWriteTool(store *EnhancedTodoStore) tool.InvokableTool

+ func NewTaskGetTool(mgr *SubagentTaskManager) tool.InvokableTool

+ func NewTaskListTool(mgr *SubagentTaskManager) tool.InvokableTool

+ func NewTaskStopTool(mgr *SubagentTaskManager) tool.InvokableTool

+ func NewTeamCreateTool(manager *team.Manager) tool.InvokableTool

+ func NewTeamDeleteTool(manager *team.Manager) tool.InvokableTool

+ func NewTeamListTool(manager *team.Manager) tool.InvokableTool

+ func NewTeamSendMessageTool(manager *team.Manager) tool.InvokableTool

+ func NewTeamSpawnTool(manager *team.Manager) tool.InvokableTool

+ func ShellQuote(s string) string

+ type AskUserAnswer struct

+ Answer string

+ QuestionHeader string

+ Selected []string

+ type AskUserBatchResponse struct

+ Answers []AskUserAnswer

+ type AskUserDeps struct

+ BatchNotifyFn func(questions []AskUserQuestion)

+ BatchResponseCh <-chan AskUserBatchResponse

+ NotifyFn func(question string, options []string)

+ ResponseCh <-chan AskUserResponse

+ type AskUserInput struct

+ Options []askUserOption

+ Question string

+ Questions []AskUserQuestion

+ type AskUserOption struct

+ Description string

+ Label string

+ type AskUserQuestion struct

+ Header string

+ MultiSelect bool

+ Options []AskUserOption

+ Question string

+ type AskUserResponse struct

+ Answer string

+ type BackgroundManager struct

+ func NewBackgroundManager(env *Env) *BackgroundManager

+ func (bm *BackgroundManager) DrainNotifications() []BgNotification

+ func (bm *BackgroundManager) GetTask(id string) *BgTask

+ func (bm *BackgroundManager) ListTasks() []*BgTask

+ func (bm *BackgroundManager) Run(ctx context.Context, command string) string

+ func (bm *BackgroundManager) RunningCount() int

+ func (bm *BackgroundManager) SetNotifier(n BgNotifier)

+ func (bm *BackgroundManager) SetStorage(s *StorageManager)

+ type BgNotification struct

+ Command string

+ Output string

+ Status BgTaskStatus

+ TaskID string

+ type BgNotifier func(taskID, command, status string)

+ type BgTask struct

+ Command string

+ Description string

+ Ended time.Time

+ ID string

+ Output string

+ Started time.Time

+ Status BgTaskStatus

+ Timeout time.Duration

+ type BgTaskStatus string

+ const BgStatusDone

+ const BgStatusFailed

+ const BgStatusRunning

+ const BgStatusTimeout

+ type CommandCategory string

+ const CmdGit

+ const CmdList

+ const CmdMutating

+ const CmdRead

+ const CmdSafe

+ const CmdSearch

+ func (c CommandCategory) IsCollapsible() bool

+ type ConflictResult struct

+ NewHash string

+ NewModTime time.Time

+ OldHash string

+ OldModTime time.Time

+ Status ConflictStatus

+ type ConflictStatus int

+ const ConflictFileGone

+ const ConflictModified

+ const ConflictNone

+ type EditInput struct

+ Edits []EditOp

+ EndLine int

+ FilePath string

+ NewString string

+ OldString string

+ ReplaceAll bool

+ StartLine int

+ type EditOp struct

+ NewString string

+ OldString string

+ type EnhancedTodoInput struct

+ Action TodoAction

+ ID string

+ Items []EnhancedTodoItem

+ Status string

+ Title string

+ Todos []TodoItem

+ type EnhancedTodoItem struct

+ BlockedBy []string

+ CreatedAt time.Time

+ ID string

+ Status string

+ Summary string

+ Title string

+ UpdatedAt time.Time

+ type EnhancedTodoStore struct

+ func NewEnhancedTodoStore(sessionID string, storage *StorageManager) *EnhancedTodoStore

+ func (s *EnhancedTodoStore) Add(items []EnhancedTodoItem) error

+ func (s *EnhancedTodoStore) HasIncomplete() bool

+ func (s *EnhancedTodoStore) HasItems() bool

+ func (s *EnhancedTodoStore) IncompleteSummary() string

+ func (s *EnhancedTodoStore) Items() []TodoItem

+ func (s *EnhancedTodoStore) Load() error

+ func (s *EnhancedTodoStore) Modify(id, status, title string) error

+ func (s *EnhancedTodoStore) Remove(id string) error

+ func (s *EnhancedTodoStore) SaveSync() error

+ func (s *EnhancedTodoStore) SetOnChange(fn func([]EnhancedTodoItem))

+ func (s *EnhancedTodoStore) Snapshot() []EnhancedTodoItem

+ func (s *EnhancedTodoStore) Summary() string

+ func (s *EnhancedTodoStore) Update(items []EnhancedTodoItem) error

+ type Env struct

+ Depth int

+ Exec Executor

+ FileTracker *FileTracker

+ OnEnvChange func(envLabel string, isLocal bool, err error)

+ TodoStore *TodoStore

+ func NewEnv(pwd, platform string) *Env

+ func (e *Env) CanNest() bool

+ func (e *Env) CloneForSubagent() *Env

+ func (e *Env) IsRemote() bool

+ func (e *Env) NewCheckBackgroundTool(bm *BackgroundManager) tool.InvokableTool

+ func (e *Env) NewEditTool() tool.InvokableTool

+ func (e *Env) NewExecuteTool(bm *BackgroundManager) tool.InvokableTool

+ func (e *Env) NewGlobTool() tool.InvokableTool

+ func (e *Env) NewGrepTool() tool.InvokableTool

+ func (e *Env) NewReadTool() tool.InvokableTool

+ func (e *Env) NewSubagentTool(deps *SubagentDeps) tool.InvokableTool

+ func (e *Env) NewSwitchEnvTool() tool.InvokableTool

+ func (e *Env) NewTodoReadTool() tool.InvokableTool

+ func (e *Env) NewTodoWriteTool() tool.InvokableTool

+ func (e *Env) NewWriteTool() tool.InvokableTool

+ func (e *Env) Pwd() string

+ func (e *Env) ResetToLocal(pwd, platform string)

+ func (e *Env) ResolvePath(path string) string

+ func (e *Env) SetSSH(executor *SSHExecutor, remotePwd string)

+ type ExecuteInput struct

+ Background bool

+ Command string

+ Timeout int

+ type Executor interface

+ Exec func(ctx context.Context, command string, workDir string, timeout time.Duration) (stdout, stderr string, err error)

+ Label func() string

+ MkdirAll func(ctx context.Context, path string, perm os.FileMode) error

+ Platform func() string

+ ReadFile func(ctx context.Context, path string) ([]byte, error)

+ Stat func(ctx context.Context, path string) (*FileInfo, error)

+ WriteFile func(ctx context.Context, path string, data []byte, perm os.FileMode) error

+ type FileInfo struct

+ Exists bool

+ IsDir bool

+ type FileState struct

+ BackupPath string

+ ContentHash string

+ ModTime time.Time

+ Path string

+ Version int

+ type FileTracker struct

+ func NewFileTracker(storage *StorageManager) *FileTracker

+ func (ft *FileTracker) CheckConflict(path string) (ConflictResult, error)

+ func (ft *FileTracker) CreateBackup(path string, content []byte) (string, error)

+ func (ft *FileTracker) TrackRead(path string, content []byte, modTime time.Time)

+ func (ft *FileTracker) UpdateAfterWrite(path string, content []byte, modTime time.Time)

+ type GlobInput struct

+ Limit int

+ MaxDepth int

+ Path string

+ Pattern string

+ type GrepInput struct

+ AfterContext int

+ BeforeContext int

+ CaseInsensitive bool

+ Context int

+ FileType string

+ Include string

+ MaxResults int

+ Multiline bool

+ Offset int

+ OutputMode string

+ Path string

+ Pattern string

+ type LocalExecutor struct

+ func NewLocalExecutor(platform string) *LocalExecutor

+ func (l *LocalExecutor) Exec(ctx context.Context, command, workDir string, timeout time.Duration) (string, string, error)

+ func (l *LocalExecutor) Label() string

+ func (l *LocalExecutor) MkdirAll(_ context.Context, path string, perm os.FileMode) error

+ func (l *LocalExecutor) Platform() string

+ func (l *LocalExecutor) ReadFile(_ context.Context, path string) ([]byte, error)

+ func (l *LocalExecutor) Stat(_ context.Context, path string) (*FileInfo, error)

+ func (l *LocalExecutor) WriteFile(_ context.Context, path string, data []byte, perm os.FileMode) error

+ type MCPCapabilities struct

+ Prompts bool

+ Resources bool

+ Tools bool

+ type MCPConnection struct

+ Capabilities *MCPCapabilities

+ Client *client.Client

+ Config *config.MCPServer

+ LastConnected time.Time

+ LastError error

+ Name string

+ RetryCount int

+ State MCPServerState

+ Tools []MCPToolInfo

+ type MCPManager struct

+ func NewMCPManager(tokenStore *TokenStore, onState func(string, MCPServerState)) *MCPManager

+ func (m *MCPManager) AddServer(ctx context.Context, name string, cfg *config.MCPServer) error

+ func (m *MCPManager) Close() error

+ func (m *MCPManager) Connect(ctx context.Context, name string, cfg *config.MCPServer) error

+ func (m *MCPManager) Disconnect(name string) error

+ func (m *MCPManager) GetAllTools() []MCPToolInfo

+ func (m *MCPManager) GetServerStatus() []MCPServerStatus

+ func (m *MCPManager) InvokeMCPTool(ctx context.Context, serverName, toolName string, args json.RawMessage) (string, error)

+ func (m *MCPManager) ListResources(ctx context.Context, serverName string) ([]MCPResource, error)

+ func (m *MCPManager) ReadResource(ctx context.Context, serverName, uri string) (string, error)

+ func (m *MCPManager) RemoveServer(name string) error

+ type MCPResource struct

+ Description string

+ MimeType string

+ Name string

+ URI string

+ type MCPServerState string

+ const MCPConnected

+ const MCPConnecting

+ const MCPDisconnected

+ const MCPFailed

+ const MCPReconnecting

+ type MCPServerStatus struct

+ Error string

+ Name string

+ State MCPServerState

+ ToolCount int

+ type MCPStatus struct

+ Error error

+ Name string

+ Running bool

+ ToolCount int

+ func LoadMCPTools(ctx context.Context, mcpConfig map[string]*config.MCPServer) ([]tool.BaseTool, []MCPStatus)

+ type MCPToolInfo struct

+ Description string

+ InputSchema json.RawMessage

+ Name string

+ ServerName string

+ type OAuthToken struct

+ AccessToken string

+ ExpiresAt time.Time

+ Provider string

+ RefreshToken string

+ Scopes []string

+ type PersistedResult struct

+ FilePath string

+ HasMore bool

+ OriginalSize int

+ Preview string

+ type PlanStatus string

+ const PlanApproved

+ const PlanDraft

+ const PlanRejected

+ const PlanSubmitted

+ type PlanStore struct

+ func NewPlanStore() *PlanStore

+ func (s *PlanStore) Approve()

+ func (s *PlanStore) Clear()

+ func (s *PlanStore) Content() string

+ func (s *PlanStore) Feedback() string

+ func (s *PlanStore) HasApprovedPlan() bool

+ func (s *PlanStore) Reject(feedback string)

+ func (s *PlanStore) SetDraft(title, content string)

+ func (s *PlanStore) Status() PlanStatus

+ func (s *PlanStore) Submit(title, content string)

+ func (s *PlanStore) Title() string

+ type ReadInput struct

+ FilePath string

+ Limit int

+ Offset int

+ type ReconnectPolicy struct

+ InitialDelay time.Duration

+ MaxDelay time.Duration

+ MaxRetries int

+ Multiplier float64

+ func DefaultReconnectPolicy() *ReconnectPolicy

+ func (p *ReconnectPolicy) Delay(retryCount int) time.Duration

+ type SSHExecutor struct

+ func NewSSHExecutor(addr, user string, authMethods []ssh.AuthMethod) (*SSHExecutor, error)

+ func (s *SSHExecutor) Close() error

+ func (s *SSHExecutor) Exec(ctx context.Context, command, workDir string, timeout time.Duration) (string, string, error)

+ func (s *SSHExecutor) Label() string

+ func (s *SSHExecutor) MkdirAll(ctx context.Context, path string, _ os.FileMode) error

+ func (s *SSHExecutor) Platform() string

+ func (s *SSHExecutor) ReadFile(ctx context.Context, path string) ([]byte, error)

+ func (s *SSHExecutor) Stat(ctx context.Context, path string) (*FileInfo, error)

+ func (s *SSHExecutor) WriteFile(ctx context.Context, path string, data []byte, perm os.FileMode) error

+ type StorageManager struct

+ func NewStorageManager(sessionID string) (*StorageManager, error)

+ func (sm *StorageManager) AppendAsync(path string, data []byte, mode os.FileMode)

+ func (sm *StorageManager) Cleanup() error

+ func (sm *StorageManager) Close() error

+ func (sm *StorageManager) FileHistoryDir() string

+ func (sm *StorageManager) OAuthDir() string

+ func (sm *StorageManager) PlansDir() string

+ func (sm *StorageManager) TasksDir() string

+ func (sm *StorageManager) TodosDir() string

+ func (sm *StorageManager) ToolResultsDir() string

+ func (sm *StorageManager) Write(path string, data []byte, mode os.FileMode) error

+ func (sm *StorageManager) WriteAsync(path string, data []byte, mode os.FileMode)

+ type StreamChunk struct

+ Data string

+ IsStderr bool

+ Timestamp time.Time

+ type SubagentDeps struct

+ ChatModel model.ToolCallingChatModel

+ ModelFactory *internalmodel.ModelFactory

+ Notifier SubagentNotifier

+ ProgressFn SubagentProgressFn

+ Recorder *session.Recorder

+ TaskManager *SubagentTaskManager

+ TokenFn SubagentTokenFn

+ type SubagentNotification struct

+ AgentType string

+ Name string

+ Status SubagentTaskStatus

+ Summary string

+ TaskID string

+ type SubagentNotifier func(name, agentType string, done bool, result string, err error)

+ type SubagentProgressFn func(agentName, event, toolName, detail string)

+ type SubagentTask struct

+ AgentType string

+ Cancel context.CancelFunc

+ Depth int

+ Ended time.Time

+ Error string

+ ID string

+ Model string

+ Name string

+ Output string

+ ParentID string

+ Started time.Time

+ Status SubagentTaskStatus

+ type SubagentTaskManager struct

+ func NewSubagentTaskManager(maxParallel, maxCompleted int) *SubagentTaskManager

+ func (m *SubagentTaskManager) DrainNotifications() []SubagentNotification

+ func (m *SubagentTaskManager) Get(taskID string) (*SubagentTask, error)

+ func (m *SubagentTaskManager) List(statusFilter SubagentTaskStatus) []*SubagentTask

+ func (m *SubagentTaskManager) RunningCount() int

+ func (m *SubagentTaskManager) Stop(taskID string) error

+ func (m *SubagentTaskManager) Submit(ctx context.Context, task *SubagentTask, ...) (taskID, result string, err error)

+ type SubagentTaskStatus string

+ const TaskStatusCompleted

+ const TaskStatusFailed

+ const TaskStatusPending

+ const TaskStatusRunning

+ const TaskStatusStopped

+ type SubagentTokenFn func(totalTokens int64)

+ type SwitchEnvInput struct

+ Target string

+ type TaskLog struct

+ func NewTaskLog(storage *StorageManager, taskID string) (*TaskLog, error)

+ func (tl *TaskLog) Close() error

+ func (tl *TaskLog) ReadAll() (string, error)

+ func (tl *TaskLog) Write(data []byte) (int, error)

+ type TodoAction string

+ const TodoActionAdd

+ const TodoActionModify

+ const TodoActionRead

+ const TodoActionRemove

+ const TodoActionUpdate

+ type TodoFileFormat struct

+ Items []EnhancedTodoItem

+ SessionID string

+ UpdatedAt time.Time

+ Version int

+ type TodoItem struct

+ ID int

+ Status TodoStatus

+ Title string

+ func ExtractTodosFromPlan(planContent string) []TodoItem

+ type TodoStatus string

+ const TodoCancelled

+ const TodoCompleted

+ const TodoInProgress

+ const TodoPending

+ type TodoStore struct

+ OnUpdate func(items []TodoItem)

+ func NewTodoStore() *TodoStore

+ func (s *TodoStore) HasIncomplete() bool

+ func (s *TodoStore) HasItems() bool

+ func (s *TodoStore) IncompleteSummary() string

+ func (s *TodoStore) Items() []TodoItem

+ func (s *TodoStore) Summary() string

+ func (s *TodoStore) Update(items []TodoItem)

+ type TokenStore struct

+ func NewTokenStore(dir string) *TokenStore

+ func (ts *TokenStore) Delete(provider string) error

+ func (ts *TokenStore) Get(provider string) (*OAuthToken, error)

+ func (ts *TokenStore) Save(provider string, token OAuthToken) error

+ type ToolProgressMsg struct

+ ElapsedSec int

+ PartialOutput string

+ ToolName string

+ type ToolResultStore struct

+ func NewToolResultStore(storage *StorageManager) *ToolResultStore

+ func (ts *ToolResultStore) PersistIfLarge(toolName, result string) (PersistedResult, bool)

+ func (ts *ToolResultStore) Retrieve(filePath string) (string, error)

+ type WriteEntry struct

+ Append bool

+ Callback func(error)

+ Data []byte

+ Mode os.FileMode

+ type WriteInput struct

+ Content string

+ FilePath string

+ type WriteQueue struct

+ func NewWriteQueue(interval time.Duration) *WriteQueue

+ func (wq *WriteQueue) Close()

+ func (wq *WriteQueue) DrainSync()

+ func (wq *WriteQueue) Enqueue(path string, entry WriteEntry)

v0.0.1

Mar 29, 2026

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