tools

package

Go to main page

Versions in this module

v1

v1.2.10

May 11, 2026

v1.2.9

May 11, 2026

v1.2.8

May 11, 2026

v1.2.7

May 11, 2026

v1.2.6

May 11, 2026

v1.2.5

May 11, 2026

v1.2.4

May 11, 2026

v1.2.3

May 11, 2026

v1.2.2

May 11, 2026

v1.2.1

May 10, 2026

Changes in this version

+ type BootstrapOptions struct

+ Config *config.Config

+ CronService *cron.CronService

+ MessageBus *bus.MessageBus

+ ProcessManager *ProcessManager

+ Provider providers.LLMProvider

+ SessionHistory SessionHistoryFunc

+ SessionList SessionListFunc

+ SessionManager *session.SessionManager

+ Workspace string

+ type BootstrapResult struct

+ ProcessManager *ProcessManager

+ Registry *ToolRegistry

+ SubagentManager *SubagentManager

+ SubagentRouter *SubagentRouter

+ func BootstrapDefaultTools(ctx context.Context, opts BootstrapOptions) (*BootstrapResult, error)

+ type SessionHistoryFunc func(key string, limit int) []providers.Message

+ type SessionListFunc func(limit int) []SessionInfo

v1.2.0

Apr 14, 2026

Changes in this version

type SubagentExecutionStats

+ CompletionTokens int

+ PromptTokens int

+ TotalTokens int

type SubagentRun

+ CompletionTokens int

+ PromptTokens int

+ TotalTokens int

v1.1.0

Apr 13, 2026

Changes in this version

+ func RecordSubagentExecutionStats(ctx context.Context, delta SubagentExecutionStats)

+ func SubagentIterationBudget(ctx context.Context) (int, bool)

+ func WithSubagentExecutionStats(ctx context.Context, stats *SubagentExecutionStats) context.Context

+ func WithSubagentIterationBudget(ctx context.Context, budget int) context.Context

type EventRecord

+ FailureCode string

+ type SessionSearchTool struct

+ func NewSessionSearchTool(manager *session.SessionManager) *SessionSearchTool

+ func (t *SessionSearchTool) Description() string

+ func (t *SessionSearchTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SessionSearchTool) Name() string

+ func (t *SessionSearchTool) ParallelSafe() bool

+ func (t *SessionSearchTool) Parameters() map[string]interface{}

+ type SubagentExecutionStats struct

+ Attempts int

+ FailureCode string

+ Iterations int

+ Restarts int

type SubagentProfile

+ MaxToolIterations int

type SubagentRun

+ AttemptCount int

+ IterationCount int

+ LastFailureCode string

+ MaxToolIterations int

+ RestartCount int

type SubagentRunEvent

+ FailureCode string

type SubagentSpawnOptions

+ MaxToolIterations int

v1.0.2

Apr 8, 2026

v1.0.1

Mar 24, 2026

v1.0.0

Mar 19, 2026

Changes in this version

type ArtifactRecord

+ RequestID string

type EventRecord

+ RequestID string

type ExecutionRun

+ Request RequestRecord

+ type RequestRecord struct

+ CorrelationID string

+ CreatedAt int64

+ ID string

+ Input string

+ OriginChannel string

+ OriginChatID string

+ OwnerAgentID string

+ Status string

+ ThreadID string

+ UpdatedAt int64

type RouterReply

+ RunID string

type RunRecord

+ RequestID string

type RuntimeSnapshot

+ Requests []RequestRecord

type SubagentManager

+ func (sm *SubagentManager) NextRunSequence() int

+ func (sm *SubagentManager) SpawnRun(ctx context.Context, opts SubagentSpawnOptions) (*SubagentRun, error)

type SubagentRouter

+ func (r *SubagentRouter) DispatchRun(ctx context.Context, req RouterDispatchRequest) (*SubagentRun, error)

+ func (r *SubagentRouter) WaitRun(ctx context.Context, runID string, interval time.Duration) (*RouterReply, error)

+ type SubagentRun struct

+ AgentID string

+ CorrelationID string

+ Created int64

+ ID string

+ Label string

+ LastMessageID string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ MemoryNS string

+ NotifyMainPolicy string

+ OriginChannel string

+ OriginChatID string

+ ParentAgentID string

+ ParentRunID string

+ Result string

+ RetryBackoff int

+ RetryCount int

+ Role string

+ SessionKey string

+ SharedState map[string]interface{}

+ Status string

+ Steering []string

+ SystemPromptFile string

+ Task string

+ ThreadID string

+ TimeoutSec int

+ ToolAllowlist []string

+ Transport string

+ Updated int64

+ WaitingReply bool

v0

v0.2.4

Mar 12, 2026

v0.2.3

Mar 12, 2026

v0.2.2

Mar 11, 2026

v0.2.1

Mar 11, 2026

v0.2.0

Mar 11, 2026

v0.0.4

Mar 16, 2026

Changes in this version

+ func BuildAgentSessionKey(agentID, taskID string) string

+ func IsWorldDecisionTask(task *AgentTask) bool

+ func OriginValues(in *OriginRef) (string, string)

+ func PromptFileFromPolicy(policy *ExecutionPolicy) string

+ func TargetNodeID(target *TargetRef) string

+ func TargetParentAgentID(target *TargetRef) string

+ func TargetTransport(target *TargetRef) string

+ func ToolAllowlistFromPolicy(policy *ExecutionPolicy) []string

+ type AgentDispatchReply struct

+ AgentID string

+ Error *RuntimeError

+ Result string

+ Run RunRecord

+ Status string

+ TaskID string

+ type AgentDispatchRequest struct

+ AgentID string

+ Decision *DispatchDecision

+ ExecutionPolicy *ExecutionPolicy

+ Origin *OriginRef

+ RunKind string

+ Target *TargetRef

+ Task string

+ WorldDecision *WorldDecisionContext

+ type AgentDispatcher struct

+ func NewAgentDispatcher(manager *AgentManager) *AgentDispatcher

+ func (r *AgentDispatcher) DispatchTask(ctx context.Context, req AgentDispatchRequest) (*AgentTask, error)

+ func (r *AgentDispatcher) MergeResults(replies []*AgentDispatchReply) string

+ func (r *AgentDispatcher) WaitReply(ctx context.Context, taskID string, interval time.Duration) (*AgentDispatchReply, error)

type AgentMailboxStore

+ func (s *AgentMailboxStore) EnsureThreadID(threadID string) string

+ type AgentManager struct

+ func NewAgentManager(provider providers.LLMProvider, workspace string, bus *bus.MessageBus) *AgentManager

+ func (sm *AgentManager) Events(taskID string, limit int) ([]AgentRunEvent, error)

+ func (sm *AgentManager) GetTask(taskID string) (*AgentTask, bool)

+ func (sm *AgentManager) HasProvider() bool

+ func (sm *AgentManager) Inbox(agentID string, limit int) ([]AgentMessage, error)

+ func (sm *AgentManager) ListTasks() []*AgentTask

+ func (sm *AgentManager) NextTaskSequence() int

+ func (sm *AgentManager) ProfileStore() *AgentProfileStore

+ func (sm *AgentManager) ResolveMemoryNamespace(agentID string) string

+ func (sm *AgentManager) RuntimeSnapshot(limit int) RuntimeSnapshot

+ func (sm *AgentManager) SendAgentMessage(fromAgent, toAgent, messageType, content, threadID string) (AgentMessage, error)

+ func (sm *AgentManager) SetRunFunc(f AgentRunFunc)

+ func (sm *AgentManager) Spawn(ctx context.Context, opts AgentSpawnOptions) (string, error)

+ func (sm *AgentManager) SpawnTask(ctx context.Context, opts AgentSpawnOptions) (*AgentTask, error)

+ func (sm *AgentManager) WaitTask(ctx context.Context, taskID string) (*AgentTask, bool, error)

+ type AgentProfile struct

+ AgentID string

+ CreatedAt int64

+ DefaultGoals []string

+ Faction string

+ HomeLocation string

+ Kind string

+ ManagedBy string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ MemoryNamespace string

+ Name string

+ NodeID string

+ ParentAgentID string

+ PerceptionScope int

+ Persona string

+ PromptFile string

+ RetryBackoff int

+ Role string

+ ScheduleHint string

+ Status string

+ TimeoutSec int

+ ToolAllowlist []string

+ Traits []string

+ Transport string

+ UpdatedAt int64

+ WorldTags []string

+ type AgentProfileStore struct

+ func NewAgentProfileStore(workspace string) *AgentProfileStore

+ func (s *AgentProfileStore) Delete(agentID string) error

+ func (s *AgentProfileStore) FindByRole(role string) (*AgentProfile, bool, error)

+ func (s *AgentProfileStore) Get(agentID string) (*AgentProfile, bool, error)

+ func (s *AgentProfileStore) List() ([]AgentProfile, error)

+ func (s *AgentProfileStore) Upsert(profile AgentProfile) (*AgentProfile, error)

+ type AgentProfileTool struct

+ func NewAgentProfileTool(store *AgentProfileStore) *AgentProfileTool

+ func (t *AgentProfileTool) Description() string

+ func (t *AgentProfileTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *AgentProfileTool) Name() string

+ func (t *AgentProfileTool) Parameters() map[string]interface{}

+ type AgentRunEvent struct

+ AgentID string

+ At int64

+ Message string

+ RetryCount int

+ RunID string

+ Status string

+ Type string

+ type AgentRunFunc func(ctx context.Context, task *AgentTask) (string, error)

+ type AgentRunStore struct

+ func NewAgentRunStore(workspace string) *AgentRunStore

+ func (s *AgentRunStore) AppendEvent(evt AgentRunEvent) error

+ func (s *AgentRunStore) AppendRun(task *AgentTask) error

+ func (s *AgentRunStore) Events(runID string, limit int) ([]AgentRunEvent, error)

+ func (s *AgentRunStore) Get(runID string) (*AgentTask, bool)

+ func (s *AgentRunStore) List() []*AgentTask

+ func (s *AgentRunStore) NextIDSeed() int

+ type AgentSpawnOptions struct

+ AgentID string

+ ExecutionPolicy *ExecutionPolicy

+ Origin *OriginRef

+ Role string

+ RunKind string

+ Target *TargetRef

+ Task string

+ WorldDecision *WorldDecisionContext

+ type AgentTask struct

+ AgentID string

+ Created int64

+ ExecutionPolicy *ExecutionPolicy

+ ID string

+ Origin *OriginRef

+ Result string

+ RetryCount int

+ RunKind string

+ Status string

+ Target *TargetRef

+ Task string

+ Updated int64

+ WorldDecision *WorldDecisionContext

+ type ExecutionPolicy struct

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ PromptFile string

+ RetryBackoff int

+ TimeoutSec int

+ ToolAllowlist []string

+ type OriginRef struct

+ Channel string

+ ChatID string

type RuntimeSnapshot

+ World interface{}

+ type TargetRef struct

+ NodeID string

+ ParentAgentID string

+ Transport string

type TaskRecord

+ Origin string

+ type WorldDecisionContext struct

+ IntentSchemaVersion string

+ NPCSnapshot map[string]interface{}

+ VisibleEvents []map[string]interface{}

+ WorldSnapshot map[string]interface{}

+ WorldTick int64

+ type WorldTool struct

+ func NewWorldTool(runtime WorldToolRuntime) *WorldTool

+ func (t *WorldTool) Description() string

+ func (t *WorldTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *WorldTool) Name() string

+ func (t *WorldTool) Parameters() map[string]interface{}

+ type WorldToolRuntime interface

+ CreateEntity func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ CreateNPC func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ CreateQuest func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ EntityGet func(id string) (map[string]interface{}, bool, error)

+ EntityList func() ([]map[string]interface{}, error)

+ EventLog func(limit int) ([]map[string]interface{}, error)

+ NPCGet func(id string) (map[string]interface{}, bool, error)

+ NPCList func() ([]map[string]interface{}, error)

+ QuestGet func(id string) (map[string]interface{}, bool, error)

+ QuestList func() ([]map[string]interface{}, error)

+ Snapshot func(limit int) (interface{}, error)

+ Tick func(ctx context.Context, source string) (string, error)

+ UpdateEntity func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ UpdateLocation func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ UpdateRoom func(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

+ WorldGet func() (map[string]interface{}, error)

v0.0.3

Mar 14, 2026

Changes in this version

+ const RuntimeStatusCancelled

+ const RuntimeStatusCompleted

+ const RuntimeStatusFailed

+ const RuntimeStatusPending

+ const RuntimeStatusRecovered

+ const RuntimeStatusRouting

+ const RuntimeStatusRunning

+ const RuntimeStatusWaiting

+ func EventRecordID(runID, eventType string, at int64) string

+ func IsTerminalRuntimeStatus(status string) bool

+ func MapBoolArg(args map[string]interface{}, key string) (bool, bool)

+ func MapIntArg(args map[string]interface{}, key string, fallback int) int

+ func MapObjectArg(args map[string]interface{}, key string) map[string]interface

+ func MapRawStringArg(args map[string]interface{}, key string) string

+ func MapStringArg(args map[string]interface{}, key string) string

+ func MapStringListArg(args map[string]interface{}, key string) []string

+ type ArtifactRecord struct

+ AgentID string

+ Content string

+ CorrelationID string

+ CreatedAt int64

+ FromAgent string

+ ID string

+ Kind string

+ Name string

+ ReplyTo string

+ RequiresReply bool

+ RunID string

+ SourceType string

+ Status string

+ TaskID string

+ ThreadID string

+ ToAgent string

+ Visible bool

+ type DispatchDecision struct

+ Confidence float64

+ Reason string

+ RouteSource string

+ TargetAgent string

+ TaskText string

+ func (d DispatchDecision) Valid() bool

+ type EventRecord struct

+ AgentID string

+ At int64

+ Error *RuntimeError

+ ID string

+ Message string

+ RetryCount int

+ RunID string

+ Status string

+ TaskID string

+ Type string

+ type ExecutionRun struct

+ Decision DispatchDecision

+ Run RunRecord

+ Task TaskRecord

type RouterDispatchRequest

+ Decision *DispatchDecision

type RouterReply

+ Error *RuntimeError

+ Run RunRecord

+ type RunRecord struct

+ AgentID string

+ CorrelationID string

+ CreatedAt int64

+ Error *RuntimeError

+ ID string

+ Input string

+ Kind string

+ Output string

+ ParentRunID string

+ Status string

+ TaskID string

+ ThreadID string

+ UpdatedAt int64

+ type RuntimeError struct

+ Code string

+ Message string

+ Retryable bool

+ Source string

+ Stage string

+ func NewRuntimeError(code, message, stage string, retryable bool, source string) *RuntimeError

+ type RuntimeSnapshot struct

+ Artifacts []ArtifactRecord

+ Events []EventRecord

+ Runs []RunRecord

+ Tasks []TaskRecord

+ Threads []ThreadRecord

type SubagentManager

+ func (sm *SubagentManager) RuntimeSnapshot(limit int) RuntimeSnapshot

+ type TaskRecord struct

+ CorrelationID string

+ CreatedAt int64

+ ID string

+ Input string

+ OriginChannel string

+ OriginChatID string

+ OwnerAgentID string

+ Status string

+ ThreadID string

+ UpdatedAt int64

+ type ThreadRecord struct

+ CreatedAt int64

+ ID string

+ OwnerAgentID string

+ Participants []string

+ Status string

+ Topic string

+ UpdatedAt int64

v0.0.2

Mar 13, 2026

v0.0.1

Mar 13, 2026

Changes in this version

+ const GlobalWatchdogTick

+ var ErrCommandNoProgress = errors.New("command no progress across tick rounds")

+ var ErrMissingField = errors.New("missing required field")

+ var ErrTaskWatchdogTimeout = errors.New("task watchdog timeout exceeded")

+ var ErrUnsupportedAction = errors.New("unsupported action")

+ func DeleteConfigSubagent(configPath, agentID string) (map[string]interface{}, error)

+ func DraftConfigSubagent(description, agentIDHint string) map[string]interface

+ func ExpandToolAllowlistEntries(entries []string) []string

+ func ParseMCPDynamicToolName(name string) (serverName string, remoteName string, ok bool)

+ func ToolToSchema(tool Tool) map[string]interface

+ func UpsertConfigSubagent(configPath string, args map[string]interface{}) (map[string]interface{}, error)

+ type AgentMailboxStore struct

+ func NewAgentMailboxStore(workspace string) *AgentMailboxStore

+ func (s *AgentMailboxStore) AppendMessage(msg AgentMessage) (AgentMessage, error)

+ func (s *AgentMailboxStore) EnsureThread(thread AgentThread) (AgentThread, error)

+ func (s *AgentMailboxStore) Inbox(agentID string, limit int) ([]AgentMessage, error)

+ func (s *AgentMailboxStore) Message(messageID string) (*AgentMessage, bool)

+ func (s *AgentMailboxStore) MessagesByThread(threadID string, limit int) ([]AgentMessage, error)

+ func (s *AgentMailboxStore) Thread(threadID string) (*AgentThread, bool)

+ func (s *AgentMailboxStore) ThreadInbox(threadID, agentID string, limit int) ([]AgentMessage, error)

+ func (s *AgentMailboxStore) UpdateMessageStatus(messageID, status string, at int64) (*AgentMessage, error)

+ type AgentMessage struct

+ Content string

+ CorrelationID string

+ CreatedAt int64

+ FromAgent string

+ MessageID string

+ ReplyTo string

+ RequiresReply bool

+ Status string

+ ThreadID string

+ ToAgent string

+ Type string

+ type AgentThread struct

+ CreatedAt int64

+ Owner string

+ Participants []string

+ Status string

+ ThreadID string

+ Topic string

+ UpdatedAt int64

+ type AliasTool struct

+ func NewAliasTool(name, description string, base Tool, argMap map[string]string) *AliasTool

+ func (t *AliasTool) Description() string

+ func (t *AliasTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *AliasTool) Name() string

+ func (t *AliasTool) Parameters() map[string]interface{}

+ type BrowserTool struct

+ func NewBrowserTool() *BrowserTool

+ func (t *BrowserTool) Description() string

+ func (t *BrowserTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *BrowserTool) Name() string

+ func (t *BrowserTool) Parameters() map[string]interface{}

+ type CameraTool struct

+ func NewCameraTool(workspace string) *CameraTool

+ func (t *CameraTool) Description() string

+ func (t *CameraTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *CameraTool) Name() string

+ func (t *CameraTool) Parameters() map[string]interface{}

+ type CatalogTool interface

+ CatalogEntry func() map[string]interface{}

+ type CronTool struct

+ func NewCronTool(cs *cron.CronService) *CronTool

+ func (t *CronTool) Description() string

+ func (t *CronTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *CronTool) Name() string

+ func (t *CronTool) Parameters() map[string]interface{}

+ type EditFileTool struct

+ func NewEditFileTool(allowedDir string) *EditFileTool

+ func (t *EditFileTool) Description() string

+ func (t *EditFileTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *EditFileTool) Name() string

+ func (t *EditFileTool) Parameters() map[string]interface{}

+ type ExecTool struct

+ func NewExecTool(cfg config.ShellConfig, workspace string, pm *ProcessManager) *ExecTool

+ func (t *ExecTool) Description() string

+ func (t *ExecTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ExecTool) Name() string

+ func (t *ExecTool) Parameters() map[string]interface{}

+ func (t *ExecTool) SetTimeout(timeout time.Duration)

+ type FunctionCall struct

+ Arguments string

+ Name string

+ type LLMProvider interface

+ Chat func(ctx context.Context, messages []Message, tools []ToolDefinition, model string, ...) (*LLMResponse, error)

+ GetDefaultModel func() string

+ type LLMResponse struct

+ Content string

+ FinishReason string

+ ToolCalls []ToolCall

+ Usage *UsageInfo

+ type ListDirTool struct

+ func NewListDirTool(allowedDir string) *ListDirTool

+ func (t *ListDirTool) Description() string

+ func (t *ListDirTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ListDirTool) Name() string

+ func (t *ListDirTool) Parameters() map[string]interface{}

+ type MCPRemoteTool struct

+ func (t *MCPRemoteTool) CatalogEntry() map[string]interface{}

+ func (t *MCPRemoteTool) Description() string

+ func (t *MCPRemoteTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MCPRemoteTool) Name() string

+ func (t *MCPRemoteTool) Parameters() map[string]interface{}

+ type MCPTool struct

+ func NewMCPTool(workspace string, cfg config.MCPToolsConfig) *MCPTool

+ func (t *MCPTool) Description() string

+ func (t *MCPTool) DiscoverTools(ctx context.Context) []Tool

+ func (t *MCPTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MCPTool) Name() string

+ func (t *MCPTool) Parameters() map[string]interface{}

+ type MemoryGetTool struct

+ func NewMemoryGetTool(workspace string) *MemoryGetTool

+ func (t *MemoryGetTool) Description() string

+ func (t *MemoryGetTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MemoryGetTool) Name() string

+ func (t *MemoryGetTool) Parameters() map[string]interface{}

+ type MemorySearchTool struct

+ func NewMemorySearchTool(workspace string) *MemorySearchTool

+ func (t *MemorySearchTool) Description() string

+ func (t *MemorySearchTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MemorySearchTool) Name() string

+ func (t *MemorySearchTool) Parameters() map[string]interface{}

+ type MemoryWriteTool struct

+ func NewMemoryWriteTool(workspace string) *MemoryWriteTool

+ func (t *MemoryWriteTool) Description() string

+ func (t *MemoryWriteTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MemoryWriteTool) Name() string

+ func (t *MemoryWriteTool) Parameters() map[string]interface{}

+ type Message struct

+ Content string

+ Role string

+ ToolCallID string

+ ToolCalls []ToolCall

+ type MessageTool struct

+ func NewMessageTool() *MessageTool

+ func (t *MessageTool) Description() string

+ func (t *MessageTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *MessageTool) Name() string

+ func (t *MessageTool) Parameters() map[string]interface{}

+ func (t *MessageTool) SetContext(channel, chatID string)

+ func (t *MessageTool) SetSendCallback(callback SendCallback)

+ type NodesTool struct

+ func NewNodesTool(m *nodes.Manager, r *nodes.Router, auditPath string) *NodesTool

+ func (t *NodesTool) Description() string

+ func (t *NodesTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *NodesTool) Name() string

+ func (t *NodesTool) Parameters() map[string]interface{}

+ type ParallelFetchTool struct

+ func NewParallelFetchTool(fetcher *WebFetchTool, maxParallelCalls int, parallelSafe map[string]struct{}) *ParallelFetchTool

+ func (t *ParallelFetchTool) Description() string

+ func (t *ParallelFetchTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ParallelFetchTool) Name() string

+ func (t *ParallelFetchTool) Parameters() map[string]interface{}

+ type ParallelSafeTool interface

+ ParallelSafe func() bool

+ type ParallelTool struct

+ func NewParallelTool(registry *ToolRegistry, maxParallelCalls int, parallelSafe map[string]struct{}) *ParallelTool

+ func (t *ParallelTool) Description() string

+ func (t *ParallelTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ParallelTool) Name() string

+ func (t *ParallelTool) Parameters() map[string]interface{}

+ type ProcessEvent struct

+ At time.Time

+ Command string

+ ExitCode *int

+ SessionID string

+ Type string

+ type ProcessManager struct

+ func NewProcessManager(workspace string) *ProcessManager

+ func (m *ProcessManager) Get(id string) (*processSession, bool)

+ func (m *ProcessManager) Kill(id string) error

+ func (m *ProcessManager) List() []map[string]interface{}

+ func (m *ProcessManager) Log(id string, offset, limit int) (string, error)

+ func (m *ProcessManager) Start(parent context.Context, command, cwd string) (string, error)

+ func (m *ProcessManager) SubscribeEvents(buffer int) <-chan ProcessEvent

+ type ProcessTool struct

+ func NewProcessTool(m *ProcessManager) *ProcessTool

+ func (t *ProcessTool) Description() string

+ func (t *ProcessTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ProcessTool) Name() string

+ func (t *ProcessTool) Parameters() map[string]interface{}

+ type ReadFileTool struct

+ func NewReadFileTool(allowedDir string) *ReadFileTool

+ func (t *ReadFileTool) Description() string

+ func (t *ReadFileTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *ReadFileTool) Name() string

+ func (t *ReadFileTool) Parameters() map[string]interface{}

+ type RemindTool struct

+ func NewRemindTool(cs *cron.CronService) *RemindTool

+ func (t *RemindTool) Description() string

+ func (t *RemindTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *RemindTool) Name() string

+ func (t *RemindTool) Parameters() map[string]interface{}

+ func (t *RemindTool) SetContext(channel, chatID string)

+ type RepoMapTool struct

+ func NewRepoMapTool(workspace string) *RepoMapTool

+ func (t *RepoMapTool) Description() string

+ func (t *RepoMapTool) Execute(_ context.Context, args map[string]interface{}) (string, error)

+ func (t *RepoMapTool) Name() string

+ func (t *RepoMapTool) Parameters() map[string]interface{}

+ type ResourceScopedTool interface

+ ResourceKeys func(args map[string]interface{}) []string

+ type RouterDispatchRequest struct

+ AgentID string

+ CorrelationID string

+ Label string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ NotifyMainPolicy string

+ OriginChannel string

+ OriginChatID string

+ ParentRunID string

+ RetryBackoff int

+ Role string

+ Task string

+ ThreadID string

+ TimeoutSec int

+ type RouterReply struct

+ AgentID string

+ CorrelationID string

+ Result string

+ Status string

+ TaskID string

+ ThreadID string

+ type SendCallback func(channel, chatID, action, content, media, messageID, emoji string, ...) error

+ type SessionInfo struct

+ CompactionCount int

+ Key string

+ Kind string

+ Summary string

+ UpdatedAt time.Time

+ type SessionsTool struct

+ func NewSessionsTool(listFn func(limit int) []SessionInfo, ...) *SessionsTool

+ func (t *SessionsTool) Description() string

+ func (t *SessionsTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SessionsTool) Name() string

+ func (t *SessionsTool) Parameters() map[string]interface{}

+ type SkillExecTool struct

+ func NewSkillExecTool(workspace string) *SkillExecTool

+ func (t *SkillExecTool) Description() string

+ func (t *SkillExecTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SkillExecTool) Name() string

+ func (t *SkillExecTool) Parameters() map[string]interface{}

+ type SpawnTool struct

+ func NewSpawnTool(manager *SubagentManager) *SpawnTool

+ func (t *SpawnTool) Description() string

+ func (t *SpawnTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SpawnTool) Name() string

+ func (t *SpawnTool) Parameters() map[string]interface{}

+ func (t *SpawnTool) SetContext(channel, chatID string)

+ type SubagentConfigTool struct

+ func NewSubagentConfigTool(configPath string) *SubagentConfigTool

+ func (t *SubagentConfigTool) Description() string

+ func (t *SubagentConfigTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SubagentConfigTool) Name() string

+ func (t *SubagentConfigTool) Parameters() map[string]interface{}

+ func (t *SubagentConfigTool) SetConfigPath(path string)

+ type SubagentManager struct

+ func NewSubagentManager(provider providers.LLMProvider, workspace string, bus *bus.MessageBus) *SubagentManager

+ func (sm *SubagentManager) AckTaskMessage(taskID, messageID string) bool

+ func (sm *SubagentManager) Events(taskID string, limit int) ([]SubagentRunEvent, error)

+ func (sm *SubagentManager) GetTask(taskID string) (*SubagentTask, bool)

+ func (sm *SubagentManager) Inbox(agentID string, limit int) ([]AgentMessage, error)

+ func (sm *SubagentManager) KillTask(taskID string) bool

+ func (sm *SubagentManager) ListTasks() []*SubagentTask

+ func (sm *SubagentManager) Message(messageID string) (*AgentMessage, bool)

+ func (sm *SubagentManager) NextTaskSequence() int

+ func (sm *SubagentManager) ProfileStore() *SubagentProfileStore

+ func (sm *SubagentManager) ReplyToTask(taskID, replyToMessageID, message string) bool

+ func (sm *SubagentManager) ResumeTask(ctx context.Context, taskID string) (string, bool)

+ func (sm *SubagentManager) SendTaskMessage(taskID, message string) bool

+ func (sm *SubagentManager) SetRunFunc(f SubagentRunFunc)

+ func (sm *SubagentManager) Spawn(ctx context.Context, opts SubagentSpawnOptions) (string, error)

+ func (sm *SubagentManager) SpawnTask(ctx context.Context, opts SubagentSpawnOptions) (*SubagentTask, error)

+ func (sm *SubagentManager) SteerTask(taskID, message string) bool

+ func (sm *SubagentManager) TaskInbox(taskID string, limit int) ([]AgentMessage, error)

+ func (sm *SubagentManager) Thread(threadID string) (*AgentThread, bool)

+ func (sm *SubagentManager) ThreadMessages(threadID string, limit int) ([]AgentMessage, error)

+ func (sm *SubagentManager) WaitTask(ctx context.Context, taskID string) (*SubagentTask, bool, error)

+ type SubagentProfile struct

+ AgentID string

+ CreatedAt int64

+ ManagedBy string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ MemoryNamespace string

+ Name string

+ NodeID string

+ NotifyMainPolicy string

+ ParentAgentID string

+ RetryBackoff int

+ Role string

+ Status string

+ SystemPromptFile string

+ TimeoutSec int

+ ToolAllowlist []string

+ Transport string

+ UpdatedAt int64

+ type SubagentProfileStore struct

+ func NewSubagentProfileStore(workspace string) *SubagentProfileStore

+ func (s *SubagentProfileStore) Delete(agentID string) error

+ func (s *SubagentProfileStore) FindByRole(role string) (*SubagentProfile, bool, error)

+ func (s *SubagentProfileStore) Get(agentID string) (*SubagentProfile, bool, error)

+ func (s *SubagentProfileStore) List() ([]SubagentProfile, error)

+ func (s *SubagentProfileStore) Upsert(profile SubagentProfile) (*SubagentProfile, error)

+ type SubagentProfileTool struct

+ func NewSubagentProfileTool(store *SubagentProfileStore) *SubagentProfileTool

+ func (t *SubagentProfileTool) Description() string

+ func (t *SubagentProfileTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SubagentProfileTool) Name() string

+ func (t *SubagentProfileTool) Parameters() map[string]interface{}

+ type SubagentRouter struct

+ func NewSubagentRouter(manager *SubagentManager) *SubagentRouter

+ func (r *SubagentRouter) DispatchTask(ctx context.Context, req RouterDispatchRequest) (*SubagentTask, error)

+ func (r *SubagentRouter) MergeResults(replies []*RouterReply) string

+ func (r *SubagentRouter) WaitReply(ctx context.Context, taskID string, interval time.Duration) (*RouterReply, error)

+ type SubagentRunEvent struct

+ AgentID string

+ At int64

+ Message string

+ RetryCount int

+ RunID string

+ Status string

+ Type string

+ type SubagentRunFunc func(ctx context.Context, task *SubagentTask) (string, error)

+ type SubagentRunStore struct

+ func NewSubagentRunStore(workspace string) *SubagentRunStore

+ func (s *SubagentRunStore) AppendEvent(evt SubagentRunEvent) error

+ func (s *SubagentRunStore) AppendRun(task *SubagentTask) error

+ func (s *SubagentRunStore) Events(runID string, limit int) ([]SubagentRunEvent, error)

+ func (s *SubagentRunStore) Get(runID string) (*SubagentTask, bool)

+ func (s *SubagentRunStore) List() []*SubagentTask

+ func (s *SubagentRunStore) NextIDSeed() int

+ type SubagentSpawnOptions struct

+ AgentID string

+ CorrelationID string

+ Label string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ NotifyMainPolicy string

+ OriginChannel string

+ OriginChatID string

+ ParentRunID string

+ RetryBackoff int

+ Role string

+ Task string

+ ThreadID string

+ TimeoutSec int

+ type SubagentTask struct

+ AgentID string

+ CorrelationID string

+ Created int64

+ ID string

+ Label string

+ LastMessageID string

+ MaxResultChars int

+ MaxRetries int

+ MaxTaskChars int

+ MemoryNS string

+ NodeID string

+ NotifyMainPolicy string

+ OriginChannel string

+ OriginChatID string

+ ParentAgentID string

+ ParentRunID string

+ Result string

+ RetryBackoff int

+ RetryCount int

+ Role string

+ SessionKey string

+ SharedState map[string]interface{}

+ Status string

+ Steering []string

+ SystemPromptFile string

+ Task string

+ ThreadID string

+ TimeoutSec int

+ ToolAllowlist []string

+ Transport string

+ Updated int64

+ WaitingReply bool

+ type SubagentsTool struct

+ func NewSubagentsTool(m *SubagentManager) *SubagentsTool

+ func (t *SubagentsTool) Description() string

+ func (t *SubagentsTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SubagentsTool) Name() string

+ func (t *SubagentsTool) Parameters() map[string]interface{}

+ type SystemInfoTool struct

+ func NewSystemInfoTool() *SystemInfoTool

+ func (t *SystemInfoTool) Description() string

+ func (t *SystemInfoTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *SystemInfoTool) Name() string

+ func (t *SystemInfoTool) Parameters() map[string]interface{}

+ type Tool interface

+ Description func() string

+ Execute func(ctx context.Context, args map[string]interface{}) (string, error)

+ Name func() string

+ Parameters func() map[string]interface{}

+ type ToolAllowlistGroup struct

+ Aliases []string

+ Description string

+ Name string

+ Tools []string

+ func ToolAllowlistGroups() []ToolAllowlistGroup

+ type ToolCall struct

+ Arguments map[string]interface{}

+ Function *FunctionCall

+ ID string

+ Name string

+ Type string

+ type ToolDefinition struct

+ Function ToolFunctionDefinition

+ Type string

+ type ToolFunctionDefinition struct

+ Description string

+ Name string

+ Parameters map[string]interface{}

+ type ToolRegistry struct

+ func NewToolRegistry() *ToolRegistry

+ func (r *ToolRegistry) Catalog() []map[string]interface{}

+ func (r *ToolRegistry) Count() int

+ func (r *ToolRegistry) Execute(ctx context.Context, name string, args map[string]interface{}) (string, error)

+ func (r *ToolRegistry) Get(name string) (Tool, bool)

+ func (r *ToolRegistry) GetDefinitions() []map[string]interface{}

+ func (r *ToolRegistry) GetSummaries() []string

+ func (r *ToolRegistry) List() []string

+ func (r *ToolRegistry) Register(tool Tool)

+ type UsageInfo struct

+ CompletionTokens int

+ PromptTokens int

+ TotalTokens int

+ type WebFetchTool struct

+ func NewWebFetchTool(maxChars int) *WebFetchTool

+ func (t *WebFetchTool) Description() string

+ func (t *WebFetchTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *WebFetchTool) Name() string

+ func (t *WebFetchTool) ParallelSafe() bool

+ func (t *WebFetchTool) Parameters() map[string]interface{}

+ type WebSearchTool struct

+ func NewWebSearchTool(apiKey string, maxResults int) *WebSearchTool

+ func (t *WebSearchTool) Description() string

+ func (t *WebSearchTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *WebSearchTool) Name() string

+ func (t *WebSearchTool) Parameters() map[string]interface{}

+ type WriteFileTool struct

+ func NewWriteFileTool(allowedDir string) *WriteFileTool

+ func (t *WriteFileTool) Description() string

+ func (t *WriteFileTool) Execute(ctx context.Context, args map[string]interface{}) (string, error)

+ func (t *WriteFileTool) Name() string

+ func (t *WriteFileTool) Parameters() map[string]interface{}

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