copilot

package

Go to main page

Versions in this module

v1

v1.18.3

Apr 27, 2026

v1.18.2

Apr 16, 2026

Changes in this version

+ func ContextWithToolOutcomeLog(ctx context.Context, log *ToolOutcomeLog) context.Context

+ func ProvenanceReason(content string, outcomes []ToolOutcome) string

type Assistant

+ func (a *Assistant) ForceDream(ctx context.Context)

type DreamConsolidator

+ func (d *DreamConsolidator) ForceRun(ctx context.Context) DreamResult

type PromptComposer

+ func (p *PromptComposer) SetLCMStore(store *LCMStore)

+ type ToolOutcome struct

+ Args string

+ Content string

+ Error bool

+ Name string

+ Timestamp time.Time

+ type ToolOutcomeLog struct

+ func NewToolOutcomeLog(capacity int) *ToolOutcomeLog

+ func ToolOutcomeLogFromContext(ctx context.Context) *ToolOutcomeLog

+ func (l *ToolOutcomeLog) Record(o ToolOutcome)

+ func (l *ToolOutcomeLog) Snapshot() []ToolOutcome

v1.18.1

Apr 13, 2026

v1.18.0

Apr 13, 2026

Changes in this version

+ func EmitHierarchyEnabled(logger *slog.Logger, enabled bool)

+ func IncClassifierPass()

+ func IncContextRouterDefault()

+ func IncContextRouterDisabled()

+ func IncContextRouterHeuristic()

+ func IncContextRouterMapped()

+ func IncL1CacheHit()

+ func IncL1CacheMiss()

+ func IncLayerTokensL0(n int)

+ func IncLayerTokensL1(n int)

+ func IncLayerTokensL2(n int)

+ func IncSaveWingRouted()

+ func IncSearchWithWingFilter()

+ func IncSearchWithoutWingFilter()

+ func IncToolCall(name string)

+ func LooksLikeCredential(content string) bool

+ func RedactCredentials(content string) string

+ func RegisterKGTools(executor *ToolExecutor, sqliteStore *memory.SQLiteStore)

+ func RegisterMemoryHierarchyTools(executor *ToolExecutor, cfg MemoryHierarchyDispatcherConfig)

type AgentConfig

+ KG KGAgentConfig

type AgentRun

+ func (a *AgentRun) SetKG(k *kg.KG)

+ type ContextRouter struct

+ func NewContextRouter(store *memory.SQLiteStore, logger *slog.Logger, cfg HierarchyConfig) *ContextRouter

+ func (r *ContextRouter) Pin(channel, externalID, wing string) error

+ func (r *ContextRouter) Resolve(ctx context.Context, channel, externalID, hint string) WingResolution

+ func (r *ContextRouter) Unpin(channel, externalID string) error

type DreamConsolidator

+ func (d *DreamConsolidator) RecordCompaction()

+ func (d *DreamConsolidator) WithHierarchyConfig(cfg HierarchyConfig) *DreamConsolidator

+ func (d *DreamConsolidator) WithSQLiteStore(s *memory.SQLiteStore) *DreamConsolidator

type DreamState

+ CompactionsSince int

+ type HierarchyConfig struct

+ AutoRoomCap int

+ AutoRoomDedupeDistance int

+ DefaultWing string

+ Enabled bool

+ EssentialStoryRoomsPerWing int

+ EssentialStoryStaleAfter time.Duration

+ Heuristics []WingHeuristic

+ IdentityPath string

+ KG KGConfig

+ L1Budget int

+ L2Budget int

+ LegacyKeywords map[string][]string

+ OnDemandCrossWingEnabled bool

+ OnDemandMaxResults int

+ TopicChangeEntityOverlap float64

+ TopicChangeThreshold float64

+ WingBoostMatch float64

+ WingBoostPenalty float64

+ func DefaultHierarchyConfig() HierarchyConfig

+ type HierarchyMetrics struct

+ ContextRouterDefault uint64

+ ContextRouterDisabled uint64

+ ContextRouterHeuristic uint64

+ ContextRouterMapped uint64

+ GetTaxonomyCalls uint64

+ ListRoomsCalls uint64

+ ListWingsCalls uint64

+ SearchWithWingFilter uint64

+ SearchWithoutWingFilter uint64

+ WingPinCalls uint64

+ WingStatusCalls uint64

+ WingUnpinCalls uint64

+ func (m *HierarchyMetrics) EmitSnapshot(logger *slog.Logger)

+ func (m *HierarchyMetrics) Global() *HierarchyMetrics

+ type KGAgentConfig struct

+ AutoExtract string

+ FactsPerInjection int

+ LLMBudgetPerCycle int

+ LLMConsentACK bool

+ type KGConfig struct

+ AutoExtract string

+ FactsPerInjection int

+ LLMBudgetPerCycle int

+ LLMConsentACK bool

type MemoryConfig

+ Dream DreamConfig

+ Hierarchy HierarchyConfig

+ Stack MemoryStackConfig

type MemoryDispatcherConfig

+ ContextRouter *ContextRouter

+ type MemoryHierarchyDispatcherConfig struct

+ Enabled bool

+ Logger *slog.Logger

+ Router *ContextRouter

+ SQLiteStore *memory.SQLiteStore

+ type MemoryStack struct

+ func NewMemoryStack(identity *memory.IdentityLayer, essential *memory.EssentialLayer, ...) *MemoryStack

+ func (s *MemoryStack) Build(ctx context.Context, activeWing, turn string) string

+ func (s *MemoryStack) Stats() StackStats

+ type MemoryStackConfig struct

+ ForceLegacy bool

+ type PalaceBotConfig struct

+ Enabled bool

+ Router *ContextRouter

+ Store *memory.SQLiteStore

+ type PalaceBotReply struct

+ Err error

+ Handled bool

+ Reply string

+ func HandlePalaceBotCommand(ctx context.Context, cfg PalaceBotConfig, channel, chatID, input string) PalaceBotReply

type PromptComposer

+ func (p *PromptComposer) SetContextRouter(router *ContextRouter)

+ func (p *PromptComposer) SetMemoryStack(stack *MemoryStack)

+ type StackConfig struct

+ ForceLegacy bool

+ TotalBudget int

+ func DefaultStackConfig() StackConfig

+ type StackStats struct

+ BuildTotal int64

+ L0Bytes int64

+ L1Bytes int64

+ L2Bytes int64

+ PanicTotal int64

+ TrimmedTotal int64

+ type WingHeuristic struct

+ MatchChannelName []string

+ MatchGroupName []string

+ Wing string

+ type WingResolution struct

+ Confidence float64

+ Source WingResolutionSource

+ Wing string

+ func (w WingResolution) IsEmpty() bool

+ type WingResolutionSource string

+ const SourceDefault

+ const SourceDisabled

+ const SourceHeuristic

+ const SourceMapped

v1.17.0

Apr 1, 2026

Changes in this version

+ func CollapseToolResults(messages []chatMessage, maxChars int) int

+ func FormatIncompleteWorkMessage(items []IncompleteWork) string

+ func FormatMemoriesForStorage(memories []ExtractedMemory, sessionID string) string

+ func MicroCompact(messages []chatMessage, keepLastN int) ([]chatMessage, int)

+ func MicroCompactByRatio(messages []chatMessage, ratio float64, cfg ContextPruningConfig) ([]chatMessage, int)

+ func SynthesizeFindings(results []WorkerResult) string

+ type CompactLevel int

+ const CompactAuto

+ const CompactCollapse

+ const CompactMemory

+ const CompactMicro

+ const CompactNone

+ func (l CompactLevel) String() string

+ type CompactThresholds struct

+ AutoCompactAt float64

+ CollapseAt float64

+ MemoryCompactAt float64

+ MicroCompactAt float64

+ func DefaultCompactThresholds() CompactThresholds

+ type CompactionCircuitBreaker struct

+ func NewCompactionCircuitBreaker(maxFailures int, cooldown time.Duration) *CompactionCircuitBreaker

+ func (cb *CompactionCircuitBreaker) Allow() bool

+ func (cb *CompactionCircuitBreaker) Failures() int

+ func (cb *CompactionCircuitBreaker) RecordFailure()

+ func (cb *CompactionCircuitBreaker) RecordSuccess()

+ type CompactionPipeline struct

+ func NewCompactionPipeline(thresholds CompactThresholds) *CompactionPipeline

+ func (p *CompactionPipeline) Evaluate(tokenCount, contextWindow int) ContextPressure

+ func (p *CompactionPipeline) LastLevel() CompactLevel

+ func (p *CompactionPipeline) RecordFailure()

+ func (p *CompactionPipeline) RecordSuccess()

+ func (p *CompactionPipeline) SetLastLevel(level CompactLevel)

+ func (p *CompactionPipeline) ShouldCompact(level CompactLevel) bool

+ type CompletionCheck struct

+ CompletionPatterns []string

+ Name string

+ Reminder string

+ TriggerPatterns []string

+ type ContextPressure struct

+ ContextWindow int

+ Ratio float64

+ RecommendedLevel CompactLevel

+ TokenCount int

+ TokensUntilBlocking int

+ type Coordinator struct

+ func NewCoordinator(config CoordinatorConfig, spawner WorkerSpawner, logger *slog.Logger) *Coordinator

+ func (c *Coordinator) GetPhaseTools(phase CoordinatorPhase) []string

+ func (c *Coordinator) MaxWorkersForPhase(phase CoordinatorPhase) int

+ func (c *Coordinator) RunPhase(ctx context.Context, phase CoordinatorPhase, tasks []WorkerTask) PhaseResult

+ type CoordinatorConfig struct

+ DefaultTimeout time.Duration

+ ImplTools []string

+ MaxImplWorkers int

+ MaxResearchWorkers int

+ MaxVerifyWorkers int

+ ResearchTools []string

+ VerifyTools []string

+ func DefaultCoordinatorConfig() CoordinatorConfig

+ type CoordinatorPhase string

+ const PhaseImplementation

+ const PhaseResearch

+ const PhaseSynthesis

+ const PhaseVerification

+ func PhaseOrder() []CoordinatorPhase

+ type DecisionPhase struct

+ func (d *DecisionPhase) Execute(ctx context.Context, state *TurnState) (NextAction, error)

+ func (d *DecisionPhase) Name() string

+ type DreamConfig struct

+ Enabled bool

+ IdleMinutes int

+ MaxMemoriesToProcess int

+ MinHoursBetween int

+ MinSessionsBetween int

+ func DefaultDreamConfig() DreamConfig

+ type DreamConsolidator struct

+ func NewDreamConsolidator(config DreamConfig, store memory.Store, stateDir string, logger *slog.Logger) *DreamConsolidator

+ func (d *DreamConsolidator) RecordSession()

+ func (d *DreamConsolidator) Run(ctx context.Context) DreamResult

+ func (d *DreamConsolidator) Start(ctx context.Context)

+ func (d *DreamConsolidator) State() DreamState

+ func (d *DreamConsolidator) Stop()

+ type DreamResult struct

+ Consolidated int

+ Contradictions int

+ Duplicates int

+ Duration time.Duration

+ Error error

+ MemoriesAnalyzed int

+ type DreamState struct

+ LastDreamAt time.Time

+ LastResult string

+ SessionsSince int

+ TotalDreams int

+ type ExtractedMemory struct

+ Content string

+ Importance int

+ Type string

+ type IncompleteWork struct

+ CheckName string

+ Reminder string

+ type MemoryExtractor struct

+ func NewMemoryExtractor(llm *LLMClient, logger *slog.Logger) *MemoryExtractor

+ func (e *MemoryExtractor) Extract(ctx context.Context, messages []chatMessage, modelOverride string) []ExtractedMemory

type MemoryIndexer

+ func (m *MemoryIndexer) MemoryDir() string

+ type NextAction int

+ const ActionContinue

+ const ActionInject

+ const ActionLoopBack

+ const ActionStop

+ func (a NextAction) String() string

+ type Phase interface

+ Execute func(ctx context.Context, state *TurnState) (NextAction, error)

+ Name func() string

+ type PhaseResult struct

+ Duration time.Duration

+ Phase CoordinatorPhase

+ Results []WorkerResult

+ type PreparePhase struct

+ func NewPreparePhase(builder func(state *TurnState) error) *PreparePhase

+ func (p *PreparePhase) Execute(ctx context.Context, state *TurnState) (NextAction, error)

+ func (p *PreparePhase) Name() string

+ type QueryLoop struct

+ func NewQueryLoop(phases ...Phase) *QueryLoop

+ func (q *QueryLoop) RunTurn(ctx context.Context, state *TurnState) (*TurnState, error)

+ func (q *QueryLoop) SetMaxIterations(n int)

+ func (q *QueryLoop) SetOnPhaseComplete(fn func(phase string, action NextAction, duration time.Duration))

+ type StopCheckPhase struct

+ func NewStopCheckPhase(v *StopHookVerifier) *StopCheckPhase

+ func (s *StopCheckPhase) Execute(ctx context.Context, state *TurnState) (NextAction, error)

+ func (s *StopCheckPhase) Name() string

+ type StopHookVerifier struct

+ func NewStopHookVerifier() *StopHookVerifier

+ func (v *StopHookVerifier) VerifyCompletion(messages []chatMessage) []IncompleteWork

type ToolExecutor

+ func (e *ToolExecutor) ApplyDefaultConcurrency()

+ func (e *ToolExecutor) IsConcurrentSafe(name string) bool

+ func (e *ToolExecutor) MarkConcurrentSafe(names ...string)

+ type TurnState struct

+ FinalText string

+ InjectedMessage string

+ Messages []chatMessage

+ Metadata map[string]any

+ Response *LLMResponse

+ ToolResults []ToolResult

+ Tools []ToolDefinition

+ Turn int

+ Usage LLMUsage

+ type WorkerResult struct

+ Duration time.Duration

+ Error error

+ Label string

+ Phase CoordinatorPhase

+ Result string

+ TaskID string

+ type WorkerSpawner func(ctx context.Context, task WorkerTask, allowedTools []string) (string, error)

+ type WorkerTask struct

+ ID string

+ Label string

+ Phase CoordinatorPhase

+ Prompt string

+ Timeout time.Duration

v1.16.11

Mar 25, 2026

v1.16.10

Mar 25, 2026

v1.16.9

Mar 25, 2026

v1.16.8

Mar 24, 2026

v1.16.7

Mar 24, 2026

v1.16.6

Mar 24, 2026

v1.16.5

Mar 23, 2026

Changes in this version

+ func NormalizeTelegramID(id string) string

+ func ResolveSecrets(cfg *Config)

type AccessManager

+ func (am *AccessManager) DefaultPolicy() AccessPolicy

+ func (am *AccessManager) ListGroupsByChannel(suffix string) []*AccessEntry

+ func (am *AccessManager) ListUsersByChannel(suffix string) []*AccessEntry

+ func (am *AccessManager) SetDefaultPolicy(policy AccessPolicy)

v1.16.4

Mar 23, 2026

v1.16.3

Mar 23, 2026

v1.16.2

Mar 23, 2026

v1.16.1

Mar 23, 2026

v1.16.0

Mar 23, 2026

Changes in this version

+ func ContextWithToolOverlay(ctx context.Context, overlay *ToolOverlay) context.Context

+ func ContextWithWorkspaceID(ctx context.Context, wsID string) context.Context

+ func FormatIdentityMd(id *IdentityConfig) string

+ func RegisterAgentTools(executor *ToolExecutor, wsMgr *WorkspaceManager)

+ func RegisterPluginAgentDelegation(executor *ToolExecutor, registry *plugins.Registry, ...)

+ func RegisterPluginManagementTools(executor *ToolExecutor, registry *plugins.Registry)

+ func ScaffoldWorkspaceDir(wsID string, ws *Workspace) error

+ func Slugify(name string) string

+ func SynthesizeProgressSummary(fragments []string) string

+ func WorkspaceIDFromContext(ctx context.Context) string

type AgentRouter

+ func (r *AgentRouter) AddProfile(p *AgentProfileConfig)

type AgentRun

+ func (a *AgentRun) CollectedAssistantFragments() []string

type Assistant

+ func (a *Assistant) PluginRegistry() *plugins.Registry

+ func (a *Assistant) ProviderDiscovery() *ProviderDiscovery

+ func (a *Assistant) SetPluginRegistry(r *plugins.Registry)

type ChannelsConfig

+ DiscordInstances map[string]discord.Config

+ SlackInstances map[string]slack.Config

+ TelegramInstances map[string]telegram.Config

+ WhatsAppInstances map[string]whatsapp.Config

+ func (c ChannelsConfig) DiscordAll() map[string]discord.Config

+ func (c ChannelsConfig) SlackAll() map[string]slack.Config

+ func (c ChannelsConfig) TelegramAll() map[string]telegram.Config

+ func (c ChannelsConfig) WhatsAppAll() map[string]whatsapp.Config

+ type DeliveryScope string

+ const DeliveryScopeAll

+ const DeliveryScopeExternal

+ const DeliveryScopeParent

+ type ErrEscalation struct

+ Signal *EscalationSignal

+ func (e *ErrEscalation) Error() string

+ type EscalationSignal struct

+ Reason string

+ Summary string

type FailoverCoordinator

+ func (fc *FailoverCoordinator) ReportFailureWithCause(model string, profileID profiles.ProfileID, statusCode int, errMsg string, ...) FailoverReason

type FailoverReason

+ func ClassifyErrorFull(statusCode int, errMsg string, cause error) FailoverReason

type GatewayConfig

+ TLS TLSConfig

type LCMConfig

+ LargeFileTokenThreshold int

+ PruneHeartbeatOK *bool

+ SummaryModel string

+ SummaryProvider string

+ type LCMFile struct

+ ConversationID string

+ CreatedAt time.Time

+ FilePath string

+ ID string

+ OriginalChars int

+ OriginalTokens int

+ Summary string

+ type LCMQueryFn func(ctx context.Context, systemPrompt, userContent string) (string, error)

type LCMRetrieval

+ func (r *LCMRetrieval) ExpandQuery(ctx context.Context, convID, query string, queryFn LCMQueryFn) (string, error)

type LCMStore

+ func (s *LCMStore) DeleteMessage(id int64) error

+ func (s *LCMStore) GetFile(id string) (*LCMFile, error)

+ func (s *LCMStore) InsertFile(f *LCMFile) error

+ func (s *LCMStore) ListFiles(convID string) ([]*LCMFile, error)

+ type MemoryPromptSectionBuilder interface

+ BuildMemorySection func(session *Session, input string) string

type ModelFailoverManager

+ func (m *ModelFailoverManager) ReportFailureWithCause(model string, statusCode int, errMsg string, cause error) FailoverReason

type PromptComposer

+ func (p *PromptComposer) RegisterMemorySectionBuilder(builder MemoryPromptSectionBuilder)

+ func (p *PromptComposer) SetPluginAgentLister(lister func() []pluginAgentInfo)

+ func (p *PromptComposer) SetWorkspaceContext(wsID string, dirs []string)

type PromptLayer

+ const LayerPluginAgents

type SQLiteSessionPersistence

+ func (p *SQLiteSessionPersistence) TruncateAfterCompaction(sessionID string, keepRecentEntries int) error

type Session

+ func (s *Session) ResetWithPreservation()

type SessionPersistence

+ func (p *SessionPersistence) TruncateAfterCompaction(sessionID string, keepRecentEntries int) error

type SessionPersister

+ TruncateAfterCompaction func(sessionID string, keepRecentEntries int) error

type SpawnParams

+ DeliveryScope DeliveryScope

+ EscalationChecker func(turn int, lastResponse string) *EscalationSignal

+ MaxTurns int

type SubagentManager

+ func (m *SubagentManager) CreateChildExecutorWithProfile(parent *ToolExecutor, depth int, allow, deny []string) *ToolExecutor

+ func (m *SubagentManager) SpawnWithExecutor(parentCtx context.Context, params SpawnParams, llmClient *LLMClient, ...) (*SubagentRun, error)

type SubagentRun

+ DeliveryScope DeliveryScope

+ RetryCount int

+ type TLSConfig struct

+ AutoGenerate bool

+ CertPath string

+ Enabled bool

+ KeyPath string

type ToolExecutor

+ func (e *ToolExecutor) RegisterPluginTool(reg plugins.ToolRegistration)

+ func (e *ToolExecutor) UnregisterTool(name string) bool

+ type ToolOverlay struct

+ Allow []string

+ Deny []string

+ func ToolOverlayFromContext(ctx context.Context) *ToolOverlay

+ type UserManagerConfig struct

+ DefaultRole string

+ MaxUsers int

type Workspace

+ Channels []string

+ Default bool

+ Identity *IdentityConfig

+ MaxTurns int

+ RunTimeout int

+ Soul string

+ Source string

+ ToolsAllow []string

+ ToolsDeny []string

type WorkspaceManager

+ func (wm *WorkspaceManager) DefaultID() string

+ func (wm *WorkspaceManager) ListSessionsForWorkspace(wsID string) []SessionInfo

+ func (wm *WorkspaceManager) RebuildMaps()

+ func (wm *WorkspaceManager) ResolveByNameOrID(input string) (*Workspace, bool)

+ func (wm *WorkspaceManager) SessionCountForWorkspace(wsID string) int

+ func (wm *WorkspaceManager) SetDefault(wsID string) error

v1.15.0

Mar 17, 2026

Changes in this version

+ func ContextWithMediaEmitter(ctx context.Context, fn MediaEmitter) context.Context

+ type MediaEmitter func(MediaEvent)

+ func MediaEmitterFromContext(ctx context.Context) MediaEmitter

+ type MediaEvent struct

+ Caption string

+ Filename string

+ ID string

+ MimeType string

+ Size int64

+ Type string

+ URL string

v1.14.0

Mar 15, 2026

Changes in this version

+ var ErrAgentYield = errors.New("agent yielded turn")

+ func ContextWithAgentRun(ctx context.Context, a *AgentRun) context.Context

+ func ContextWithFastMode(ctx context.Context, fast bool) context.Context

+ func ContextWithMessageID(ctx context.Context, msgID string) context.Context

+ func EstimateTokens(s string) int

+ func GenerateSummaryID(content string, ts time.Time) string

+ func MessageIDFromCtx(ctx context.Context) string

+ func RegisterLCMDispatcher(executor *ToolExecutor, engine *LCMEngine)

+ func RegisterSessionsYieldTool(executor *ToolExecutor)

type AgentRun

+ func AgentRunFromCtx(ctx context.Context) *AgentRun

+ func (a *AgentRun) SetLCMEngine(engine *LCMEngine, conversationID string)

+ func (a *AgentRun) SetMemoryIndexer(m *MemoryIndexer)

+ func (a *AgentRun) SetReactionSender(fn func(emoji string, remove bool))

+ func (a *AgentRun) SetSession(s *Session)

type CompactionConfig

+ CompactionModel string

+ ContextPruning ContextPruningConfig

+ LCM LCMConfig

+ LCMEnabled *bool

+ PostIndexSync string

+ QualityGuard QualityGuardConfig

+ TimeoutSeconds int

+ type ContextPruningConfig struct

+ HardClearRatio float64

+ ProtectRecentTurns int

+ SoftTrimMaxChars int

+ SoftTrimRatio float64

type HeartbeatConfig

+ IsolateSession bool

+ type LCMAssembler struct

+ func NewLCMAssembler(store *LCMStore, cfg LCMConfig, logger *slog.Logger) *LCMAssembler

+ func (a *LCMAssembler) AssembleContext(convID, systemPrompt, userMessage string, tokenBudget int) ([]chatMessage, error)

+ type LCMCompactor struct

+ func NewLCMCompactor(store *LCMStore, cfg LCMConfig, logger *slog.Logger) *LCMCompactor

+ func (c *LCMCompactor) CondensedPass(ctx context.Context, convID string, summarizeFn LCMSummarizeFn) ([]*LCMSummary, error)

+ func (c *LCMCompactor) FullSweep(ctx context.Context, convID string, summarizeFn LCMSummarizeFn) ([]*LCMSummary, error)

+ func (c *LCMCompactor) LeafPass(ctx context.Context, convID string, summarizeFn LCMSummarizeFn) ([]*LCMSummary, error)

+ func (c *LCMCompactor) ShouldCompact(convID string, contextWindowTokens int) (bool, string)

+ type LCMConfig struct

+ CondensedMaxChildren int

+ CondensedMinChildren int

+ FreshTailCount int

+ HardTriggerRatio float64

+ LeafChunkMaxTokens int

+ MaxSummaryTokens int

+ SoftTriggerRatio float64

+ type LCMContextItem struct

+ ConversationID string

+ ID int64

+ ItemType string

+ MessageID *int64

+ Ordinal int

+ SummaryID *string

+ type LCMConversation struct

+ CreatedAt time.Time

+ ID string

+ LastCompactAt time.Time

+ NextSeq int

+ SessionID string

+ type LCMEngine struct

+ func NewLCMEngine(db *sql.DB, cfg LCMConfig, ccfg CompactionConfig, logger *slog.Logger) *LCMEngine

+ func (e *LCMEngine) Assemble(ctx context.Context, convID, systemPrompt, userMessage string, tokenBudget int) ([]chatMessage, error)

+ func (e *LCMEngine) Bootstrap(sessionID string) (string, error)

+ func (e *LCMEngine) Compact(ctx context.Context, convID string, contextWindowTokens int, ...) (bool, error)

+ func (e *LCMEngine) Ingest(ctx context.Context, convID string, messages []chatMessage) error

+ func (e *LCMEngine) Retrieval() *LCMRetrieval

+ func (e *LCMEngine) Store() *LCMStore

+ type LCMFTSResult struct

+ Content string

+ EntityID string

+ EntityType string

+ Rank float64

+ type LCMMessage struct

+ Content string

+ ConversationID string

+ CreatedAt time.Time

+ ID int64

+ Role string

+ Seq int

+ TokenCount int

+ type LCMRetrieval struct

+ func NewLCMRetrieval(store *LCMStore, logger *slog.Logger) *LCMRetrieval

+ func (r *LCMRetrieval) Describe(convID, summaryID string) (string, error)

+ func (r *LCMRetrieval) DescribeTree(convID string) (string, error)

+ func (r *LCMRetrieval) Expand(convID, summaryID string, depth int) (string, error)

+ func (r *LCMRetrieval) Grep(convID, query string, isRegex bool, limit int) (string, error)

+ type LCMStore struct

+ func NewLCMStore(db *sql.DB, logger *slog.Logger) *LCMStore

+ func (s *LCMStore) CountUnsummarizedTokens(convID string, excludeLastN int) (int, error)

+ func (s *LCMStore) GetAllSummaries(convID string) ([]*LCMSummary, error)

+ func (s *LCMStore) GetContextItems(convID string) ([]LCMContextItem, error)

+ func (s *LCMStore) GetFreshTailMessages(convID string, count int) ([]*LCMMessage, error)

+ func (s *LCMStore) GetMaxDepth(convID string) (int, error)

+ func (s *LCMStore) GetMessage(id int64) (*LCMMessage, error)

+ func (s *LCMStore) GetMessageRange(convID string, fromSeq, toSeq int) ([]*LCMMessage, error)

+ func (s *LCMStore) GetOrCreateConversation(sessionID string) (*LCMConversation, error)

+ func (s *LCMStore) GetOrphanSummaries(convID string, depth int) ([]*LCMSummary, error)

+ func (s *LCMStore) GetRecentMessages(convID string, limit int) ([]*LCMMessage, error)

+ func (s *LCMStore) GetRootSummaries(convID string) ([]*LCMSummary, error)

+ func (s *LCMStore) GetSummary(id string) (*LCMSummary, error)

+ func (s *LCMStore) GetSummaryChildren(summaryID string) ([]*LCMSummary, error)

+ func (s *LCMStore) GetSummaryMessages(summaryID string) ([]*LCMMessage, error)

+ func (s *LCMStore) GetSummaryParents(summaryID string) ([]*LCMSummary, error)

+ func (s *LCMStore) GetUnsummarizedMessages(convID string, excludeLastN int) ([]*LCMMessage, error)

+ func (s *LCMStore) IngestMessage(convID, role, content string, tokenCount int) (*LCMMessage, error)

+ func (s *LCMStore) InsertSummary(sum *LCMSummary) error

+ func (s *LCMStore) LinkSummaryChildren(parentID string, childIDs []string) error

+ func (s *LCMStore) LinkSummaryMessages(summaryID string, msgIDs []int64) error

+ func (s *LCMStore) MessageCount(convID string) (int, error)

+ func (s *LCMStore) NextSeq(convID string) (int, error)

+ func (s *LCMStore) ReplaceContextItems(convID string, items []LCMContextItem) error

+ func (s *LCMStore) SearchFTS(convID, query string, limit int) ([]LCMFTSResult, error)

+ func (s *LCMStore) SummaryCount(convID string) (leaf, condensed int, err error)

+ func (s *LCMStore) UpdateLastCompactAt(convID string) error

+ type LCMSummarizeFn func(ctx context.Context, text string, aggressive bool) (string, error)

+ type LCMSummary struct

+ Content string

+ ConversationID string

+ CreatedAt time.Time

+ Depth int

+ DescendantCount int

+ DescendantTokenCount int

+ EarliestAt time.Time

+ ID string

+ Kind string

+ LatestAt time.Time

+ SourceMessageTokenCount int

+ TokenCount int

type LLMErrorKind

+ const LLMErrorThinking

+ type QualityGuardConfig struct

+ Enabled *bool

+ MaxRetries int

+ StrictIdentifiers bool

type Session

+ func (s *Session) GetCompactionCount() int

+ func (s *Session) GetFastMode() bool

+ func (s *Session) IncrementCompactionCount()

type SessionConfig

+ FastMode bool

v1.13.3

Mar 11, 2026

v1.13.2

Mar 11, 2026

v1.13.1

Mar 11, 2026

v1.13.0

Mar 11, 2026

Changes in this version

+ const ActClick

+ const ActDrag

+ const ActEvaluate

+ const ActFill

+ const ActHover

+ const ActPress

+ const ActResize

+ const ActSelect

+ const ActType

+ const ActWait

+ const CompactedPlaceholder

+ const ContextBudgetRatio

+ const ContextWindowHardMinTokens

+ const ContextWindowWarnBelowTokens

+ const DefaultImagePruneAfterTurns

+ const DefaultMaxHistoryDM

+ const DefaultMaxHistoryGroup

+ const MaxTailChars

+ const MaxToolResultContextShare

+ const MinKeepChars

+ const PerResultContextCap

+ const TailBudgetRatio

+ const TailDetectionWindow

+ var ContentRoles = map[string]bool

+ var InteractiveRoles = map[string]bool

+ var StructuralRoles = map[string]bool

+ func ApplyTranscriptPolicy(messages []chatMessage, policy TranscriptPolicy) []chatMessage

+ func ExtractLinksFromMessage(body string, maxLinks int) []string

+ func ExtractReadableText(r io.Reader) (title string, text string)

+ func FormatLinkResults(results []LinkResult) string

+ func GuardToolResultContext(messages []chatMessage, contextWindowTokens int) []chatMessage

+ func HasImportantTail(text string) bool

+ func HistoryLimitForType(isGroup bool) int

+ func InferProfileForChannel(channel string) string

+ func IsLikelyContextOverflowError(errMsg string) bool

+ func IsMutatingToolCall(name string, args map[string]any) bool

+ func IsMutatingToolName(name string) bool

+ func IsRecoverableToolError(errMsg string) bool

+ func RegisterLegacyAliases(executor *ToolExecutor)

+ func RegisterSchedulerDispatcher(executor *ToolExecutor, sched *scheduler.Scheduler, skillDB *SkillDB)

+ func RegisterSessionsDispatcher(executor *ToolExecutor, wm *WorkspaceManager)

+ func RegisterVaultTools(executor *ToolExecutor, vault *Vault)

+ func RepairToolUseResultPairing(messages []chatMessage) []chatMessage

+ func ResolveContextWindowTokens(configOverride int, modelName string) int

+ func SanitizeToolCallID(id string, mode ToolCallIDMode) string

+ func ScaledMaxRetries(profileCount int) int

+ func SetGlobalMediaRegistry(r *MediaRegistry)

+ func StartPersistentSessionReaper(ctx context.Context, storePath string, maxAgeDays int, logger *slog.Logger)

+ func StripDangerousTags(s string) string

+ func TruncateToolResult(text string, maxChars int) string

+ func ValidateIdentity(id IdentityConfig) []string

+ type AXNode struct

+ Children []*AXNode

+ Description AXValue

+ Name AXValue

+ NodeID string

+ Properties any

+ Ref string

+ Role AXRole

+ Value AXValue

+ type AXRole struct

+ Value string

+ func (r *AXRole) UnmarshalJSON(data []byte) error

+ func (r AXRole) String() string

+ type AXValue struct

+ Value string

+ func (v *AXValue) UnmarshalJSON(data []byte) error

+ func (v AXValue) String() string

+ type ActRequest struct

+ Button string

+ DoubleClick bool

+ EndRef string

+ Fields []FormField

+ Function string

+ Height int

+ Key string

+ Kind string

+ Modifiers []string

+ Ref string

+ Selector string

+ Slowly bool

+ StartRef string

+ Submit bool

+ Text string

+ TextGone string

+ TimeMs int

+ Values []string

+ Width int

+ type ActResult struct

+ Message string

+ OK bool

type AgentConfig

+ Compaction CompactionConfig

+ ContextTokens int

+ ToolVerbose VerboseLevel

type AgentProfileConfig

+ Identity *IdentityConfig

type AgentRun

+ func (a *AgentRun) CollectedToolCalls() []ToolCallRecord

+ func (a *AgentRun) SetSessionPersistence(p SessionPersister, sessionID string)

+ func (a *AgentRun) ToolSummary() string

type Assistant

+ func (a *Assistant) ProfileManager() profiles.ProfileManager

+ func (a *Assistant) ReloadAndInitializeSkills(ctx context.Context) (int, error)

+ func (a *Assistant) UpdateLLMClient(cfg *Config)

type BrowserConfig

+ AttachOnly bool

+ DefaultProfile string

+ ExtraArgs []string

+ Profiles map[string]BrowserProfile

+ SSRFPolicy BrowserSSRFPolicy

type BrowserManager

+ func (bm *BrowserManager) Act(ctx context.Context, req ActRequest) (*ActResult, error)

+ func (bm *BrowserManager) CloseTab(ctx context.Context, targetID string) error

+ func (bm *BrowserManager) FocusTab(ctx context.Context, targetID string) error

+ func (bm *BrowserManager) GetAccessibilityTree(ctx context.Context) (*AXNode, error)

+ func (bm *BrowserManager) GetCurrentTab(ctx context.Context) (*Tab, error)

+ func (bm *BrowserManager) ListTabs(ctx context.Context) ([]Tab, error)

+ func (bm *BrowserManager) NavigateTab(ctx context.Context, targetID, url string) error

+ func (bm *BrowserManager) OpenTab(ctx context.Context, url string) (*Tab, error)

+ func (bm *BrowserManager) ResolveRefToSelector(refID string) (string, error)

+ func (bm *BrowserManager) Snapshot(ctx context.Context, opts SnapshotOptions) (*SnapshotResult, error)

+ type BrowserProfile struct

+ CDPPort int

+ CDPUrl string

+ Color string

+ Driver string

+ Name string

+ type BrowserSSRFPolicy struct

+ AllowPrivateNetwork bool

+ AllowedHostnames []string

type BuiltinSkills

+ func (bs *BuiltinSkills) OnDemandSkills() []*BuiltinSkill

+ type CDPTarget struct

+ Attached bool

+ TargetID string

+ Title string

+ Type string

+ URL string

+ WebSocketDebuggerURL string

+ type CompactionConfig struct

+ IdentifierPolicy string

+ KeepRecentUserTurns int

+ MaxToolFailures int

+ ToolFailurePreviewChars int

+ func DefaultCompactionConfig() CompactionConfig

type Config

+ Browser BrowserConfig

+ DevToolsEnabled *bool

+ Identity IdentityConfig

+ Links LinkConfig

+ OAuthHub OAuthHubConfig

+ ProfileCooldowns *profiles.ProfileCooldownConfig

+ ProviderDiscovery ProviderDiscoveryConfig

+ Sessions SessionReaperConfig

+ Update UpdateConfig

+ type ConsoleMessage struct

+ Column int

+ Level string

+ Line int

+ Text string

+ Type string

+ URL string

+ type ContextEngine interface

+ Gather func(ctx context.Context, session *Session, input string, maxTokens int) string

+ Name func() string

+ type ContextEngineRegistry struct

+ func NewContextEngineRegistry() *ContextEngineRegistry

+ func (r *ContextEngineRegistry) Engines() []string

+ func (r *ContextEngineRegistry) GatherAll(ctx context.Context, session *Session, input string, maxTokensPerEngine int) string

+ func (r *ContextEngineRegistry) Register(engine ContextEngine)

+ type ContextWindowGuardResult struct

+ Message string

+ ShouldBlock bool

+ ShouldWarn bool

+ Tokens int

+ func EvaluateContextWindowGuard(tokens int) ContextWindowGuardResult

type ConversationEntry

+ ToolCalls []ToolCallRecord

+ ToolSummary string

type DaemonManager

+ func (dm *DaemonManager) ClearDaemon(label string) error

+ func (dm *DaemonManager) PollDaemon(label string) (string, error)

+ func (dm *DaemonManager) WriteToDaemon(label, input string) error

+ type DedupCache struct

+ func NewDedupCache(ttl time.Duration) *DedupCache

+ func (dc *DedupCache) CheckAndRecord(key string) bool

+ func (dc *DedupCache) IsDuplicate(key string) bool

+ func (dc *DedupCache) Record(key string)

+ func (dc *DedupCache) Stop()

+ type DiscoveredModel struct

+ ContextWindow int

+ Name string

+ ParameterSize string

+ Provider string

+ type FailoverCoordinator struct

+ func NewFailoverCoordinator(profileMgr profiles.ProfileManager, modelCfg ModelFallbackConfig, ...) *FailoverCoordinator

+ func (fc *FailoverCoordinator) GetModelManager() *ModelFailoverManager

+ func (fc *FailoverCoordinator) HasProfileManager() bool

+ func (fc *FailoverCoordinator) ReportFailure(model string, profileID profiles.ProfileID, statusCode int, errMsg string) FailoverReason

+ func (fc *FailoverCoordinator) ReportSuccess(model string, profileID profiles.ProfileID)

+ func (fc *FailoverCoordinator) SelectModelAndProfile(provider, modelOverride string, fallbacksOverride ...string) (model string, profileID profiles.ProfileID, apiKey string, err error)

type FailoverReason

+ const FailoverAuthPermanent

+ const FailoverModelNotFound

+ const FailoverSessionExpired

+ type FormField struct

+ Ref string

+ Type string

+ Value string

type HookEvent

+ const HookBeforeReset

+ const HookMessagePreprocessed

+ const HookMessageTranscribed

+ type HookRequirements struct

+ Bins []string

+ Env []string

+ OS []string

+ func (r *HookRequirements) Met() bool

type HookSummary

+ Requires *HookRequirements

+ type IdentityConfig struct

+ Avatar string

+ Creature string

+ Emoji string

+ Name string

+ Theme string

+ Vibe string

+ func ParseIdentityFile(content string) IdentityConfig

+ func ResolveIdentity(cfg *Config, agentProfile *AgentProfileConfig, identityFileContent string) IdentityConfig

+ func (ic IdentityConfig) EffectiveName(fallback string) string

+ func (ic IdentityConfig) IsEmpty() bool

+ type InlineDirectives struct

+ Language string

+ Model string

+ Queue string

+ Think string

+ Verbose *bool

+ func ParseInlineDirectives(body string) (InlineDirectives, string)

+ func (d InlineDirectives) HasAny() bool

type LLMClient

+ func (c *LLMClient) SetFailoverCoordinator(fc *FailoverCoordinator)

type LLMUsage

+ CacheReadTokens int

+ CacheWriteTokens int

+ type LegacyContextEngine struct

+ func NewLegacyContextEngine(_ *PromptComposer) *LegacyContextEngine

+ func (e *LegacyContextEngine) Gather(_ context.Context, _ *Session, _ string, _ int) string

+ func (e *LegacyContextEngine) Name() string

+ type LinkConfig struct

+ Enabled bool

+ MaxCharsPerURL int

+ MaxLinks int

+ TimeoutSeconds int

+ func DefaultLinkConfig() LinkConfig

+ type LinkResult struct

+ Content string

+ Error error

+ Title string

+ URL string

+ func RunLinkUnderstanding(ctx context.Context, urls []string, cfg LinkConfig, ...) []LinkResult

+ type MCPToolsBridge struct

+ func NewMCPToolsBridge(executor *ToolExecutor, logger *slog.Logger) *MCPToolsBridge

+ func (b *MCPToolsBridge) ConnectAll(ctx context.Context, servers []ManagedMCPServerConfig)

+ func (b *MCPToolsBridge) Shutdown()

+ type MediaCapability string

+ const CapabilityTranscription

+ const CapabilityVision

type MediaConfig

+ ConcurrencyLimit int

+ TranscriptionProviders []MediaProviderConfig

+ VisionProviders []MediaProviderConfig

+ type MediaProviderConfig struct

+ APIKey string

+ BaseURL string

+ Model string

+ Priority int

+ Provider string

+ type MediaRegistry struct

+ func GetGlobalMediaRegistry() *MediaRegistry

+ func NewMediaRegistry(visionProviders, transcriptionProviders []MediaProviderConfig, ...) *MediaRegistry

+ func (r *MediaRegistry) DescribeImageWithFallback(ctx context.Context, ...) (string, error)

+ func (r *MediaRegistry) HasTranscriptionProviders() bool

+ func (r *MediaRegistry) HasVisionProviders() bool

+ func (r *MediaRegistry) TranscribeAudioWithFallback(ctx context.Context, audioData []byte, filename, model string, ...) (string, error)

type MemoryFlushConfig

+ ProactiveEnabled bool

+ ProjectionThreshold float64

type MessageQueue

+ func (q *MessageQueue) IsDuplicate(msg *channels.IncomingMessage) bool

+ func (q *MessageQueue) SetChannelDebounce(m map[string]int)

type ModelFailoverManager

+ func (m *ModelFailoverManager) ApplyClassifiedFailure(model string, reason FailoverReason)

+ func (m *ModelFailoverManager) MarkProbed(model string)

+ func (m *ModelFailoverManager) SelectFromChain(chain []string) string

+ func (m *ModelFailoverManager) ShouldProbe(model string) bool

+ type NetworkRequest struct

+ Headers map[string]string

+ Method string

+ Status int

+ Timestamp int64

+ Type string

+ URL string

+ type OAuthHubConfig struct

+ APIKey string

+ APIKeyEnvVar string

+ HubURL string

+ Mode string

+ type PageState struct

+ ConsoleMessages []ConsoleMessage

+ LastSnapshot *SnapshotResult

+ NetworkRequests []NetworkRequest

type PluginManager

+ func (pm *PluginManager) HasPlugins() bool

type PromptComposer

+ func (p *PromptComposer) ComposeForSubagent() string

+ func (p *PromptComposer) IncrementSkillsVersion()

+ func (p *PromptComposer) SetAgentProfile(profile *AgentProfileConfig)

+ func (p *PromptComposer) SetContextEngines(registry *ContextEngineRegistry)

+ type ProviderDiscovery struct

+ func NewProviderDiscovery(cfg ProviderDiscoveryConfig, logger *slog.Logger) *ProviderDiscovery

+ func (pd *ProviderDiscovery) DiscoverAll(ctx context.Context)

+ func (pd *ProviderDiscovery) GetContextWindow(model string) int

+ func (pd *ProviderDiscovery) ListModels() []DiscoveredModel

+ type ProviderDiscoveryConfig struct

+ Enabled bool

+ OllamaURL string

+ TimeoutSeconds int

+ VLLMAPIKey string

+ VLLMURL string

type QueueConfig

+ ChannelDebounce map[string]int

+ type QueueDirective struct

+ Cap int

+ DebounceMs int

+ Drop QueueDropPolicy

+ Mode QueueMode

+ func ParseQueueDirective(args string) *QueueDirective

+ type Ref struct

+ Name string

+ Nth int

+ Role string

type RegisteredHook

+ Requires *HookRequirements

type SQLiteSessionPersistence

+ func (p *SQLiteSessionPersistence) ListSessionsMeta() ([]SessionMeta, error)

+ type SecurityAuditToolConfig struct

+ AllowSudo bool

+ DataDir string

+ EmbeddingCfg memory.EmbeddingConfig

+ GatewayConfig GatewayConfig

+ SSRFGuard *security.SSRFGuard

+ Vault *Vault

type Session

+ func (s *Session) AddCompactionSummary(entry CompactionEntry)

+ func (s *Session) AddMessageWithToolCalls(userMsg, assistantResp string, toolCalls []ToolCallRecord)

+ func (s *Session) AddMessageWithTools(userMsg, assistantResp, toolSummary string)

+ func (s *Session) EstimateHistorySizeBytes() int

+ func (s *Session) GetCompactionSummaries() []CompactionEntry

+ func (s *Session) GetLastCallTokens() (promptTokens, outputTokens, cacheRead, cacheWrite int)

+ func (s *Session) GetMaxHistory() int

+ func (s *Session) SetMaxHistory(n int)

+ func (s *Session) UpdateLastCallTokens(promptTokens, outputTokens, cacheRead, cacheWrite int)

type SessionConfig

+ ToolProfile string

+ type SessionLock struct

+ func AcquireSessionLock(sessionsDir, sessionID string, logger *slog.Logger) (*SessionLock, error)

+ func (sl *SessionLock) Release()

type SessionMeta

+ Title string

+ type SessionMetaLister interface

+ ListSessionsMeta func() ([]SessionMeta, error)

+ type SessionReaperConfig struct

+ Enabled bool

+ MaxAgeDays int

type SessionStore

+ func (ss *SessionStore) ListAllSessions() []SessionMeta

type SkillInfo

+ HasReferences bool

+ Location string

+ type SkillReloadCallback func(ctx context.Context) (int, error)

+ type SkillWatcher struct

+ func NewSkillWatcher(dirs []string, composer *PromptComposer, logger *slog.Logger) (*SkillWatcher, error)

+ func (sw *SkillWatcher) Stop()

type SkillsConfig

+ Limits skills.SkillsLimitsConfig

+ PersonalDir string

+ ProjectDir string

+ type SnapshotOptions struct

+ Compact bool

+ InteractiveOnly bool

+ MaxDepth int

+ type SnapshotResult struct

+ Refs map[string]Ref

+ Snapshot string

+ Stats SnapshotStats

+ func (s *SnapshotResult) SortedRefs() []string

+ type SnapshotStats struct

+ Chars int

+ Interactive int

+ Lines int

+ Refs int

+ type StreamSanitizer struct

+ func NewStreamSanitizer(cb StreamCallback) *StreamSanitizer

+ func (s *StreamSanitizer) Callback() StreamCallback

+ func (s *StreamSanitizer) Flush()

+ func (s *StreamSanitizer) Write(chunk string)

type SubagentManager

+ func (m *SubagentManager) StartPeriodicSweeper(ctx context.Context, interval time.Duration, maxAgeDays int)

type SubagentRun

+ func (r *SubagentRun) Done() <-chan struct{}

+ type Tab struct

+ TargetID string

+ Title string

+ Type string

+ URL string

+ type ToolCallIDMode int

+ const ToolCallIDStrict

+ const ToolCallIDStrict9

+ func ProviderToolCallIDMode(provider string) ToolCallIDMode

+ type ToolCallRecord struct

+ Args string

+ ID string

+ Name string

+ Result string

type ToolExecutor

+ func (e *ToolExecutor) ProfileManager() profiles.ProfileManager

+ func (e *ToolExecutor) RegisterHidden(def ToolDefinition, handler ToolHandlerFunc)

+ func (e *ToolExecutor) SetProfileManager(pm profiles.ProfileManager)

type ToolProfile

+ func ExtendProfileWithSkills(base *ToolProfile, activeSkills []string) *ToolProfile

+ type TranscriptPolicy struct

+ CollapseMultipleSystemMessages bool

+ DropThinkingBlocks bool

+ EnforceTurnOrdering bool

+ MaxSystemMessages int

+ MergeConsecutiveSameRole bool

+ RequireToolResultsAfterToolUse bool

+ StrictToolCallIDs bool

+ StripCacheControl bool

+ func GetTranscriptPolicy(provider string) TranscriptPolicy

+ type TypingController struct

+ func NewTypingController(channelMgr *channels.Manager, channel, chatID string) *TypingController

+ func (tc *TypingController) MarkDispatchIdle()

+ func (tc *TypingController) MarkRunComplete()

+ func (tc *TypingController) Seal()

+ func (tc *TypingController) ShouldSuppress(content string) bool

+ func (tc *TypingController) Start(ctx context.Context)

+ type TypingState int

+ const TypingActive

+ const TypingDispatchIdle

+ const TypingRunComplete

+ const TypingSealed

+ const TypingStarted

+ type UpdateConfig struct

+ AssetsURL string

+ CheckInterval string

+ Enabled bool

+ type UsageAccumulator struct

+ CallCount int

+ LastCacheRead int

+ LastCacheWrite int

+ LastInput int

+ LastOutput int

+ TotalCacheRead int

+ TotalCacheWrite int

+ TotalInput int

+ TotalOutput int

+ func (ua *UsageAccumulator) EffectiveContextTokens() int

+ func (ua *UsageAccumulator) Record(usage LLMUsage)

+ func (ua *UsageAccumulator) ToLLMUsage() LLMUsage

+ type VerboseLevel string

+ const VerboseFull

+ const VerboseOff

+ const VerboseOn

+ func (v VerboseLevel) ShouldEmitToolProgress() bool

+ type WebFetchCache struct

+ func NewWebFetchCache(ttl time.Duration, maxSize int) *WebFetchCache

+ func (c *WebFetchCache) Get(url string) (string, bool)

+ func (c *WebFetchCache) Set(url, content string)

type WebSearchConfig

+ CacheTTLSeconds int

+ PerplexityAPIKey string

+ PerplexityModel string

v1.12.0

Feb 26, 2026

Changes in this version

+ const AddFileMarker

+ const BeginPatchMarker

+ const ChangeContextMarker

+ const DeleteFileMarker

+ const EOFMarker

+ const EmptyChangeContextMarker

+ const EndPatchMarker

+ const MoveToMarker

+ const UpdateFileMarker

+ func CategorizeToolNames(names []string) map[string][]string

+ func CategorizeTools(tools []ToolDefinition) map[string][]ToolDefinition

+ func CheckSkillSetup(skill skills.Skill, vault skills.VaultReader) (*skills.SetupStatus, error)

+ func ContextWithVaultReader(ctx context.Context, vr skills.VaultReader) context.Context

+ func FormatAbortReply(stoppedSubagents int) string

+ func FormatSetupPrompt(skillName string, status *skills.SetupStatus) string

+ func FormatToolNamesForPrompt(names []string) string

+ func FormatToolsForPrompt(tools []ToolDefinition, maxDescLen int) string

+ func GetDeliveryTarget(ctx context.Context) (channel, chatID string)

+ func HasAbortPrefix(text string) bool

+ func InferToolCategory(name string) string

+ func IsAbortRequestText(text string) bool

+ func IsAbortTrigger(text string) bool

+ func RegisterApplyPatchTool(executor *ToolExecutor)

+ func RegisterMemoryTools(executor *ToolExecutor, cfg MemoryDispatcherConfig)

+ func RegisterSkillDBTools(executor *ToolExecutor, skillDB *SkillDB)

+ func RunAsync(ctx context.Context, config AsyncToolConfig, ...)

+ func SkillNeedsSetup(skill skills.Skill, vault skills.VaultReader) bool

+ func VaultReaderFromContext(ctx context.Context) skills.VaultReader

+ type AddFileHunk struct

+ Contents string

+ Path string

type AgentConfig

+ MemoryFlush MemoryFlushConfig

+ type ApplyPatchResult struct

+ Added []string

+ Deleted []string

+ Modified []string

+ Text string

+ type AsyncCompleteCallback func(result *ToolResult)

+ type AsyncToolConfig struct

+ Label string

+ OnComplete AsyncCompleteCallback

+ Timeout time.Duration

+ type BuiltinSkill struct

+ Content string

+ Description string

+ Name string

+ Trigger string

+ type BuiltinSkills struct

+ func GetBuiltinSkills() *BuiltinSkills

+ func LoadBuiltinSkills(logger *slog.Logger) *BuiltinSkills

+ func (bs *BuiltinSkills) All() map[string]*BuiltinSkill

+ func (bs *BuiltinSkills) FormatForPrompt() string

+ func (bs *BuiltinSkills) FormatSkillForPrompt(name string) string

+ func (bs *BuiltinSkills) Get(name string) *BuiltinSkill

+ func (bs *BuiltinSkills) Names() []string

+ type CompactionEntry struct

+ CompactedAt time.Time

+ MessagesAfter int

+ MessagesBefore int

+ Summary string

+ Type string

+ type ContextualTool interface

+ SetDeliveryTarget func(channel, chatID string)

+ type DeleteFileHunk struct

+ Path string

+ type DestructiveCheckResult struct

+ Allowed bool

+ BatchWarning string

+ CooldownRemaining time.Duration

+ Reason string

+ RequiresUserInput bool

+ type DestructiveToolsConfig struct

+ BatchThreshold int

+ CooldownSeconds int

+ Enabled bool

+ RateLimitPerMinute int

+ RequireInteractiveConfirmation bool

+ Tools []string

+ func DefaultDestructiveToolsConfig() DestructiveToolsConfig

+ type DestructiveTracker struct

+ func NewDestructiveTracker(cfg DestructiveToolsConfig, logger *slog.Logger) *DestructiveTracker

+ func (d *DestructiveTracker) Check(toolName string) DestructiveCheckResult

+ func (d *DestructiveTracker) IsDestructive(toolName string) bool

+ func (d *DestructiveTracker) RecordCall(toolName string)

+ func (d *DestructiveTracker) Reset()

+ func (d *DestructiveTracker) Stats() map[string]any

type HookEvent

+ const HookBeforeModelResolve

+ const HookBeforePromptBuild

+ const HookLLMInput

+ const HookLLMOutput

+ const HookToolResultPersist

type HookPayload

+ LLMInput string

+ LLMOutput string

+ Model string

+ SystemPrompt string

+ ToolCallID string

+ type Hunk struct

+ Add *AddFileHunk

+ Delete *DeleteFileHunk

+ Kind HunkKind

+ Update *UpdateFileHunk

+ type HunkKind string

+ const HunkAdd

+ const HunkDelete

+ const HunkUpdate

type LLMClient

+ func (c *LLMClient) IsOAuthProvider() bool

+ func (c *LLMClient) OAuthBaseProvider() string

+ func (c *LLMClient) SetOAuthTokenManager(tm OAuthTokenManager)

+ type MMRConfig struct

+ Enabled bool

+ Lambda float64

+ type MemoryDispatcherConfig struct

+ Config MemoryConfig

+ SQLiteStore *memory.SQLiteStore

+ Store *memory.FileStore

+ type MemoryFlushConfig struct

+ Enabled bool

+ FlushThreshold int

+ Prompt string

+ ReserveTokensFloor int

+ SystemPrompt string

+ type OAuthTokenManager interface

+ GetValidToken func(provider string) (interface{}, error)

type PromptComposer

+ func (p *PromptComposer) ComposeWithMode(session *Session, input string, mode PromptMode) string

+ func (p *PromptComposer) SetBuiltinSkills(skills *BuiltinSkills)

+ func (p *PromptComposer) SetSkillLister(lister func() []SkillInfo)

+ func (p *PromptComposer) SetToolExecutor(executor *ToolExecutor)

type PromptLayer

+ const LayerBuiltinSkills

+ const LayerProjectContext

+ type PromptMode string

+ const PromptModeFull

+ const PromptModeMinimal

+ const PromptModeNone

+ type QueryOptions struct

+ Limit int

+ Offset int

+ Order string

+ OrderBy string

+ Where map[string]any

+ type ReminderInfo struct

+ Channel string

+ ChatID string

+ Command string

+ CreatedAt string

+ ID string

+ JobID string

+ JobType string

+ RemovedAt string

+ Schedule string

+ Status string

type SQLiteSessionPersistence

+ func (p *SQLiteSessionPersistence) SaveCompaction(sessionID string, entry CompactionEntry) error

type SearchConfig

+ MMR MMRConfig

+ TemporalDecay TemporalDecayConfig

type SessionPersistence

+ func (p *SessionPersistence) SaveCompaction(sessionID string, entry CompactionEntry) error

type SessionPersister

+ SaveCompaction func(sessionID string, entry CompactionEntry) error

+ type Settings struct

+ ToolProfiles map[string]ToolProfile

+ type SettingsManager struct

+ func NewSettingsManager() *SettingsManager

+ func (sm *SettingsManager) AddProfile(profile ToolProfile) error

+ func (sm *SettingsManager) DeleteProfile(name string) error

+ func (sm *SettingsManager) GetAllProfiles() map[string]ToolProfile

+ func (sm *SettingsManager) GetSettingsPath() string

+ func (sm *SettingsManager) ListProfilesInfo() []ToolProfileInfo

+ func (sm *SettingsManager) Load() (*Settings, error)

+ func (sm *SettingsManager) Save(settings *Settings) error

+ func (sm *SettingsManager) UpdateProfile(profile ToolProfile) error

+ type SkillDB struct

+ func OpenSkillDatabase(dataDir string) (*SkillDB, error)

+ func (s *SkillDB) Close() error

+ func (s *SkillDB) CreateTable(skillName, tableName, displayName, description string, ...) error

+ func (s *SkillDB) Delete(skillName, tableName, rowID string) error

+ func (s *SkillDB) DescribeTable(skillName, tableName string) (*TableInfo, error)

+ func (s *SkillDB) DropTable(skillName, tableName string) error

+ func (s *SkillDB) GetByID(skillName, tableName, rowID string) (map[string]any, error)

+ func (s *SkillDB) GetReminderByJobID(jobID string) (*ReminderInfo, error)

+ func (s *SkillDB) InitRemindersTable() error

+ func (s *SkillDB) Insert(skillName, tableName string, data map[string]any) (string, error)

+ func (s *SkillDB) ListTables(skillName string) ([]TableInfo, error)

+ func (s *SkillDB) MarkReminderRemoved(jobID string) error

+ func (s *SkillDB) Path() string

+ func (s *SkillDB) Query(skillName, tableName string, filters map[string]any, limit int) ([]map[string]any, error)

+ func (s *SkillDB) QueryWithOptions(skillName, tableName string, opts QueryOptions) ([]map[string]any, error)

+ func (s *SkillDB) SaveReminder(jobID, jobType, schedule, command, channel, chatID string) error

+ func (s *SkillDB) SearchReminders(query string, includeRemoved bool, limit int) ([]ReminderInfo, error)

+ func (s *SkillDB) Update(skillName, tableName, rowID string, data map[string]any) error

+ type SkillInfo struct

+ Description string

+ Name string

+ Tools []string

+ type TableInfo struct

+ CreatedAt string

+ Description string

+ DisplayName string

+ RowCount int

+ Schema map[string]string

+ SkillName string

+ TableName string

+ UpdatedAt string

type TeamManager

+ func (tm *TeamManager) ResolveTeam(teamRef string) (*Team, error)

+ type TemporalDecayConfig struct

+ Enabled bool

+ HalfLifeDays float64

type ToolExecutor

+ func (e *ToolExecutor) SetVault(vault skills.VaultReader)

type ToolGuardConfig

+ DestructiveProtection DestructiveToolsConfig

type ToolLoopConfig

+ ProgressDetection bool

+ type ToolProfileInfo struct

+ Allow []string

+ Builtin bool

+ Deny []string

+ Description string

+ Name string

type ToolResult

+ ForLLM string

+ ForUser string

+ IsAsync bool

+ IsSilent bool

+ func AsyncResult(message string) *ToolResult

+ func DualToolResult(forLLM, forUser string) *ToolResult

+ func ErrorResult(err error) *ToolResult

+ func SilentResult(content string) *ToolResult

+ func (r *ToolResult) GetForLLM() string

+ func (r *ToolResult) GetForUser() string

+ type UpdateFileChunk struct

+ ChangeContext string

+ IsEndOfFile bool

+ NewLines []string

+ OldLines []string

+ type UpdateFileHunk struct

+ Chunks []UpdateFileChunk

+ MovePath string

+ Path string

type Vault

+ func (v *Vault) Has(name string) bool

+ type VaultReaderAdapter struct

+ func NewVaultReaderAdapter(getKey func(key string) (string, error), hasKey func(key string) bool) *VaultReaderAdapter

+ func (v *VaultReaderAdapter) Get(key string) (string, error)

+ func (v *VaultReaderAdapter) Has(key string) bool

v1.11.1

Feb 22, 2026

v1.11.0

Feb 22, 2026

v1.10.0

Feb 22, 2026

Changes in this version

type ActivityType

+ const ActivityNotification

+ type DestinationType string

+ const DestActivity

+ const DestChannel

+ const DestInbox

+ const DestOwner

+ const DestWebhook

+ type NotificationConditions struct

+ AgentIDs []string

+ Labels []string

+ MinPriority int

+ TaskStatus []TaskStatus

+ type NotificationConfig struct

+ Defaults NotificationDefaults

+ Enabled bool

+ QuietHours *QuietHoursConfig

+ RateLimitPerHour int

+ Rules []NotificationRule

+ type NotificationDefaults struct

+ ActivityFeed bool

+ Channel string

+ ChatID string

+ Owner bool

+ type NotificationDestination struct

+ Channel string

+ ChatID string

+ Format string

+ Target string

+ Type DestinationType

+ type NotificationDispatcher struct

+ func NewNotificationDispatcher(db *sql.DB, teamMgr *TeamManager, channelMgr *channels.Manager, ...) *NotificationDispatcher

+ func (nd *NotificationDispatcher) Dispatch(ctx context.Context, notif *TeamNotification) error

+ func (nd *NotificationDispatcher) DispatchError(ctx context.Context, teamID, agentID, agentName, message string, err error) error

+ func (nd *NotificationDispatcher) DispatchProgress(ctx context.Context, ...) error

+ func (nd *NotificationDispatcher) DispatchTaskCompletion(ctx context.Context, ...) error

+ func (nd *NotificationDispatcher) GetNotifications(ctx context.Context, teamID string, limit int) ([]*TeamNotification, error)

+ func (nd *NotificationDispatcher) GetUnreadNotifications(ctx context.Context, teamID string) ([]*TeamNotification, error)

+ func (nd *NotificationDispatcher) MarkNotificationRead(ctx context.Context, notificationID string) error

+ func (nd *NotificationDispatcher) SetConfig(config *NotificationConfig)

+ type NotificationResult string

+ const ResultFailure

+ const ResultInfo

+ const ResultSuccess

+ const ResultWarning

+ type NotificationRule struct

+ Conditions NotificationConditions

+ CreatedAt time.Time

+ Destinations []NotificationDestination

+ Enabled bool

+ Events []NotificationType

+ ID string

+ Name string

+ Priority int

+ QuietHours *QuietHoursConfig

+ RateLimit int

+ TeamID string

+ Template string

+ UpdatedAt time.Time

+ type NotificationType string

+ const NotifAgentError

+ const NotifDocumentCreated

+ const NotifHeartbeatAlert

+ const NotifMentionReceived

+ const NotifTaskBlocked

+ const NotifTaskCompleted

+ const NotifTaskFailed

+ const NotifTaskProgress

type QuietHoursConfig

+ Days []int

+ Enabled bool

type TeamManager

+ func (tm *TeamManager) DeleteTeam(teamID string) error

+ func (tm *TeamManager) NotifyTaskCompletion(ctx context.Context, ...)

+ func (tm *TeamManager) SetNotificationDispatcher(nd *NotificationDispatcher)

+ func (tm *TeamManager) StartAgent(agentID string) error

+ func (tm *TeamManager) UpdateAgent(agent *PersistentAgent) error

+ func (tm *TeamManager) UpdateTeam(team *Team) error

type TeamMemory

+ func (tm *TeamMemory) DeleteAllData() error

+ func (tm *TeamMemory) DeleteTask(taskID string) error

+ type TeamNotification struct

+ Action string

+ AgentID string

+ AgentName string

+ Details map[string]any

+ ID string

+ Message string

+ Priority int

+ Read bool

+ ReadAt *time.Time

+ Result NotificationResult

+ TaskID string

+ TaskTitle string

+ TeamID string

+ Timestamp time.Time

+ Type NotificationType

v1.9.0

Feb 22, 2026

v1.8.9

Feb 22, 2026

v1.8.8

Feb 22, 2026

v1.8.7

Feb 22, 2026

v1.8.6

Feb 22, 2026

v1.8.5

Feb 22, 2026

v1.8.4

Feb 22, 2026

v1.8.3

Feb 22, 2026

v1.8.2

Feb 22, 2026

v1.8.1

Feb 22, 2026

Changes in this version

+ var ProviderKeyNames = map[string]string

+ func GetProviderKeyName(provider string) string

type Vault

+ func (v *Vault) InjectProviderKeys() error

v1.8.0

Feb 22, 2026

Changes in this version

+ func ContextWithSpawnDepth(ctx context.Context, depth int) context.Context

+ func RegisterDBHubTools(executor *ToolExecutor, hub *database.Hub)

+ func RegisterNativeMediaTools(executor *ToolExecutor, mediaSvc *media.MediaService, ...)

+ func RegisterTeamTools(executor *ToolExecutor, teamMgr *TeamManager, db *sql.DB, ...)

+ func SpawnDepthFromContext(ctx context.Context) int

+ type ActivityType string

+ const ActivityAgentActive

+ const ActivityAgentIdle

+ const ActivityDocumentCreated

+ const ActivityDocumentUpdated

+ const ActivityFactCreated

+ const ActivityMention

+ const ActivityMessageSent

+ const ActivitySubscribed

+ const ActivityTaskAssigned

+ const ActivityTaskCompleted

+ const ActivityTaskCreated

+ const ActivityTaskUpdated

+ type AgentLevel string

+ const AgentLevelIntern

+ const AgentLevelLead

+ const AgentLevelSpecialist

+ type AgentStatus string

+ const AgentStatusActive

+ const AgentStatusBlocked

+ const AgentStatusError

+ const AgentStatusIdle

+ const AgentStatusStopped

+ type AgentWorkingState struct

+ AgentID string

+ Context string

+ CurrentTaskID string

+ NextSteps string

+ Status string

+ TeamID string

+ UpdatedAt time.Time

type Assistant

+ func (a *Assistant) GetMediaService() *media.MediaService

type Config

+ NativeMedia NativeMediaConfig

+ Routines RoutinesConfig

type DatabaseConfig

+ Hub database.HubConfig

+ func (c DatabaseConfig) Effective() database.HubConfig

+ type DocumentType string

+ const DocumentTypeDeliverable

+ const DocumentTypeNotes

+ const DocumentTypeProtocol

+ const DocumentTypeResearch

+ type MemoryChunk struct

+ Content string

+ CreatedAt time.Time

+ Filepath string

+ Hash string

+ type MemoryIndexer struct

+ func NewMemoryIndexer(cfg MemoryIndexerConfig, logger *slog.Logger) *MemoryIndexer

+ func (m *MemoryIndexer) ForceReindex()

+ func (m *MemoryIndexer) IndexNow()

+ func (m *MemoryIndexer) SetDeleteFileFunc(fn func(filepath string) error)

+ func (m *MemoryIndexer) SetIndexChunkFunc(fn func(chunks []MemoryChunk) error)

+ func (m *MemoryIndexer) SetMemoryDir(dir string)

+ func (m *MemoryIndexer) SetSQLiteStore(store SQLiteMemoryStore)

+ func (m *MemoryIndexer) Start(ctx context.Context) error

+ func (m *MemoryIndexer) Stats() (indexedTotal, indexedLast, deletedTotal int64, lastIndexTime time.Time)

+ func (m *MemoryIndexer) Stop()

+ type MemoryIndexerConfig struct

+ Enabled bool

+ Interval time.Duration

+ MemoryDir string

+ func DefaultMemoryIndexerConfig() MemoryIndexerConfig

+ type MetricsCollector struct

+ func NewMetricsCollector(cfg MetricsCollectorConfig, logger *slog.Logger) *MetricsCollector

+ func (m *MetricsCollector) Latest() *MetricsSnapshot

+ func (m *MetricsCollector) RecordAgentRunComplete(success bool, timedOut bool)

+ func (m *MetricsCollector) RecordAgentRunStart()

+ func (m *MetricsCollector) RecordDBQuery(slow bool)

+ func (m *MetricsCollector) RecordError()

+ func (m *MetricsCollector) RecordLatency(ms int64)

+ func (m *MetricsCollector) RecordMessage()

+ func (m *MetricsCollector) RecordSessionCreated()

+ func (m *MetricsCollector) RecordSubagentComplete(success bool)

+ func (m *MetricsCollector) RecordSubagentSpawn()

+ func (m *MetricsCollector) RecordTokens(count int64)

+ func (m *MetricsCollector) RecordToolCall(success bool)

+ func (m *MetricsCollector) SetDBSizeFunc(fn func() int64)

+ func (m *MetricsCollector) SetMessagesQueueFunc(fn func() int64)

+ func (m *MetricsCollector) SetSessionsCountFunc(fn func() int64)

+ func (m *MetricsCollector) SetSubagentsCountFunc(fn func() int64)

+ func (m *MetricsCollector) Start(ctx context.Context) error

+ func (m *MetricsCollector) Stop()

+ func (m *MetricsCollector) Subscribe() <-chan MetricsSnapshot

+ func (m *MetricsCollector) Unsubscribe(ch <-chan MetricsSnapshot)

+ type MetricsCollectorConfig struct

+ Enabled bool

+ Interval time.Duration

+ Webhook string

+ func DefaultMetricsCollectorConfig() MetricsCollectorConfig

+ type MetricsSnapshot struct

+ AgentRunsActive int64

+ AgentRunsFailed int64

+ AgentRunsSuccess int64

+ AgentRunsTimeout int64

+ AgentRunsTotal int64

+ DBQueries int64

+ DBSizeMB int64

+ DBSlowQuery int64

+ ErrorsRecent int64

+ ErrorsTotal int64

+ Goroutines int64

+ LatencyAvgMs int64

+ LatencyP50Ms int64

+ LatencyP99Ms int64

+ MemoryAllocMB int64

+ MemorySysMB int64

+ MessagesPerMinute int64

+ MessagesTotal int64

+ SessionsActive int64

+ SessionsTotal int64

+ SubagentsActive int64

+ SubagentsFailed int64

+ SubagentsSuccess int64

+ SubagentsTotal int64

+ Timestamp time.Time

+ TokensPerMinute int64

+ TokensTotal int64

+ ToolCallsFailed int64

+ ToolCallsSuccess int64

+ ToolCallsTotal int64

+ UptimeSeconds int64

+ type NativeMediaConfig struct

+ Enabled bool

+ Enrichment NativeMediaEnrichmentConfig

+ Service NativeMediaServiceConfig

+ Store NativeMediaStoreConfig

+ func DefaultNativeMediaConfig() NativeMediaConfig

+ type NativeMediaEnrichmentConfig struct

+ AutoEnrichAudio bool

+ AutoEnrichDocuments bool

+ AutoEnrichImages bool

+ type NativeMediaServiceConfig struct

+ CleanupEnabled bool

+ CleanupInterval string

+ MaxAudioSize int64

+ MaxDocSize int64

+ MaxImageSize int64

+ TempTTL string

+ type NativeMediaStoreConfig struct

+ BaseDir string

+ MaxFileSize int64

+ TempDir string

+ type PendingMessage struct

+ Content string

+ CreatedAt time.Time

+ Delivered bool

+ DeliveredAt *time.Time

+ FromAgent string

+ FromUser string

+ ID string

+ ThreadID string

+ ToAgent string

+ type PersistentAgent struct

+ CreatedAt time.Time

+ CurrentTaskID string

+ HeartbeatJobID string

+ HeartbeatSchedule string

+ ID string

+ Instructions string

+ LastActiveAt time.Time

+ LastHeartbeatAt *time.Time

+ Level AgentLevel

+ Model string

+ Name string

+ Personality string

+ Role string

+ SessionID string

+ Skills []string

+ Status AgentStatus

+ TeamID string

+ type RoutinesConfig struct

+ MemoryIndexer MemoryIndexerConfig

+ Metrics MetricsCollectorConfig

+ func DefaultRoutinesConfig() RoutinesConfig

+ type SQLiteMemoryStore interface

+ DeleteByFilepath func(filepath string) error

+ GetIndexedFiles func() (map[string]string, error)

+ IndexChunks func(chunks []MemoryChunk) error

type SpawnParams

+ SpawnDepth int

type SubagentConfig

+ MaxChildrenPerAgent int

+ MaxSpawnDepth int

type SubagentRun

+ ChildrenCount int

+ SpawnDepth int

+ type SubscriptionReason string

+ const SubscriptionAssigned

+ const SubscriptionAuto

+ const SubscriptionManual

+ const SubscriptionMentioned

+ type TaskStatus string

+ const TaskStatusAssigned

+ const TaskStatusBlocked

+ const TaskStatusCancelled

+ const TaskStatusDone

+ const TaskStatusInbox

+ const TaskStatusProgress

+ const TaskStatusReview

+ type Team struct

+ CreatedAt time.Time

+ DefaultModel string

+ Description string

+ Enabled bool

+ ID string

+ Name string

+ OwnerJID string

+ WorkspacePath string

+ type TeamActivity struct

+ AgentID string

+ CreatedAt time.Time

+ ID string

+ Message string

+ RelatedID string

+ TeamID string

+ Type ActivityType

+ type TeamDocument struct

+ Author string

+ Content string

+ CreatedAt time.Time

+ DocType DocumentType

+ FilePath string

+ Format string

+ ID string

+ TaskID string

+ TeamID string

+ Title string

+ UpdatedAt time.Time

+ Version int

+ type TeamFact struct

+ Author string

+ CreatedAt time.Time

+ ID string

+ Key string

+ TeamID string

+ UpdatedAt time.Time

+ Value string

+ type TeamManager struct

+ func NewTeamManager(db *sql.DB, sched *scheduler.Scheduler, logger *slog.Logger) *TeamManager

+ func (tm *TeamManager) BuildAgentSystemPrompt(agent *PersistentAgent, teamMemory *TeamMemory) string

+ func (tm *TeamManager) ClearAgentWorkingState(agentID string) error

+ func (tm *TeamManager) CreateAgent(teamID, name, role, personality, instructions, model string, skills []string, ...) (*PersistentAgent, error)

+ func (tm *TeamManager) CreateTeam(name, description, ownerJID, defaultModel string) (*Team, error)

+ func (tm *TeamManager) DeleteAgent(agentID string) error

+ func (tm *TeamManager) FindAgentByName(name string) (*PersistentAgent, error)

+ func (tm *TeamManager) GetAgent(agentID string) (*PersistentAgent, error)

+ func (tm *TeamManager) GetAgentWorkingState(agentID string) (*AgentWorkingState, error)

+ func (tm *TeamManager) GetTeam(teamID string) (*Team, error)

+ func (tm *TeamManager) GetTeamMemory(teamID string) *TeamMemory

+ func (tm *TeamManager) ListAgents(teamID string) ([]*PersistentAgent, error)

+ func (tm *TeamManager) ListTeams() ([]*Team, error)

+ func (tm *TeamManager) ParseMentions(text string) []string

+ func (tm *TeamManager) RecordHeartbeat(agentID string) error

+ func (tm *TeamManager) SaveAgentWorkingState(state *AgentWorkingState) error

+ func (tm *TeamManager) SendToAgent(ctx context.Context, toAgentID, fromAgent, message string) error

+ func (tm *TeamManager) SetAgentCurrentTask(agentID, taskID string) error

+ func (tm *TeamManager) SetSpawnAgentCallback(fn func(ctx context.Context, agent *PersistentAgent, task string) error)

+ func (tm *TeamManager) StopAgent(agentID string) error

+ func (tm *TeamManager) UpdateAgentStatus(agentID string, status AgentStatus) error

+ type TeamMemory struct

+ func NewTeamMemory(teamID string, db *sql.DB, logger *slog.Logger) *TeamMemory

+ func (tm *TeamMemory) AssignTask(taskID string, assignees []string, assignedBy string) error

+ func (tm *TeamMemory) BuildTeamContext(agentID string) (string, error)

+ func (tm *TeamMemory) CreateDocument(title string, docType DocumentType, content, format, taskID, author string) (*TeamDocument, error)

+ func (tm *TeamMemory) CreateTask(title, description, createdBy string, assignees []string) (*TeamTask, error)

+ func (tm *TeamMemory) DeleteDocument(docID string) error

+ func (tm *TeamMemory) DeleteFact(key string) error

+ func (tm *TeamMemory) GenerateStandup() (string, error)

+ func (tm *TeamMemory) GetActivities(limit int) ([]*TeamActivity, error)

+ func (tm *TeamMemory) GetDocument(docID string) (*TeamDocument, error)

+ func (tm *TeamMemory) GetFacts() ([]*TeamFact, error)

+ func (tm *TeamMemory) GetPendingMessages(agentID string, markDelivered bool) ([]*PendingMessage, error)

+ func (tm *TeamMemory) GetSubscribedThreads(agentID string) ([]string, error)

+ func (tm *TeamMemory) GetTask(taskID string) (*TeamTask, error)

+ func (tm *TeamMemory) GetTasksForAgent(agentID string) ([]*TeamTask, error)

+ func (tm *TeamMemory) GetThreadMessages(threadID string, limit int) ([]*TeamMessage, error)

+ func (tm *TeamMemory) GetThreadSubscribers(threadID string) ([]string, error)

+ func (tm *TeamMemory) ListDocuments(taskID string, docType DocumentType) ([]*TeamDocument, error)

+ func (tm *TeamMemory) ListTasks(statusFilter TaskStatus, assigneeFilter string) ([]*TeamTask, error)

+ func (tm *TeamMemory) NotifySubscribers(threadID, fromAgent, content string, excludeAgents []string) error

+ func (tm *TeamMemory) PostMessage(threadID, fromAgent, content string, mentions []string) (*TeamMessage, error)

+ func (tm *TeamMemory) SaveFact(key, value, author string) error

+ func (tm *TeamMemory) SearchFacts(query string) ([]*TeamFact, error)

+ func (tm *TeamMemory) SetTeamManager(mgr *TeamManager)

+ func (tm *TeamMemory) SubscribeToThread(threadID, agentID string, reason SubscriptionReason) error

+ func (tm *TeamMemory) UnsubscribeFromThread(threadID, agentID string) error

+ func (tm *TeamMemory) UpdateDocument(docID, content, updatedBy string) error

+ func (tm *TeamMemory) UpdateTask(taskID string, status TaskStatus, comment, updatedBy string) error

+ type TeamMessage struct

+ Content string

+ CreatedAt time.Time

+ Delivered bool

+ FromAgent string

+ FromUser string

+ ID string

+ Mentions []string

+ TeamID string

+ ThreadID string

+ type TeamTask struct

+ Assignees []string

+ BlockedReason string

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ CreatedBy string

+ Description string

+ ID string

+ Labels []string

+ Priority int

+ Status TaskStatus

+ TeamID string

+ Title string

+ UpdatedAt time.Time

+ type ThreadSubscription struct

+ AgentID string

+ ID string

+ Reason SubscriptionReason

+ SubscribedAt time.Time

+ TeamID string

+ ThreadID string

v1.7.0

Feb 20, 2026

Changes in this version

+ const ApprovalTimeout

+ const DedupWindowSec

+ const DefaultDebounceMs

+ const DefaultLLMCallTimeout

+ const DefaultMaxCompactionAttempts

+ const DefaultMaxHistory

+ const DefaultMaxPending

+ const DefaultRunTimeout

+ const DefaultSessionTTL

+ const DefaultToolTimeout

+ const FollowupDebounceMs

+ const HardMaxToolResultChars

+ const MaxMessageDefault

+ const MaxMessageWhatsApp

+ const TokenHeartbeatOK

+ const TokenNoReply

+ const VaultFile

+ var AllHookEvents = []HookEvent

+ var BuiltInProfiles = map[string]ToolProfile

+ var DefaultSubagentDeniedTools = []string

+ var ErrInvalidTime = errorString("invalid time format")

+ var ToolGroups = map[string][]string

+ func AuditSecrets(cfg *Config, logger *slog.Logger)

+ func CallerJIDFromContext(ctx context.Context) string

+ func ContextWithCaller(ctx context.Context, level AccessLevel, jid string) context.Context

+ func ContextWithDelivery(ctx context.Context, channel, chatID string) context.Context

+ func ContextWithProgressSender(ctx context.Context, fn ProgressSender) context.Context

+ func ContextWithSession(ctx context.Context, sessionID string) context.Context

+ func ContextWithToolProfile(ctx context.Context, profile *ToolProfile) context.Context

+ func DeleteKeyring(key string) error

+ func DetectInjectionPattern(text string) bool

+ func ExpandProfileList(items []string, allTools []string) []string

+ func ExpandToolGroups(names []string) []string

+ func ExtractTokenFromMessage(content string) string

+ func FindConfigFile() string

+ func FormatCollectedMessages(msgs []*channels.IncomingMessage) string

+ func FormatForChannel(text, channel string) string

+ func FormatForPlainText(text string) string

+ func FormatForSlack(text string) string

+ func FormatForTelegram(text string) string

+ func FormatForWhatsApp(text string) string

+ func GetKeyring(key string) string

+ func HookEventDescription(ev HookEvent) string

+ func IsCommand(content string) bool

+ func IsEnvReference(s string) bool

+ func KeyringAvailable() bool

+ func ListProfiles(customProfiles map[string]ToolProfile) []string

+ func MakeSessionID(channel, chatID string) string

+ func MatchesPattern(toolName, pattern string) bool

+ func MigrateKeyToKeyring(apiKey string, logger *slog.Logger) error

+ func MigrateToSQLite(db *sql.DB, dataDir string, logger *slog.Logger)

+ func OpenDatabase(path string) (*sql.DB, error)

+ func ReadPassword(prompt string) (string, error)

+ func RegisterBrowserTools(executor *ToolExecutor, browserMgr *BrowserManager, logger *slog.Logger)

+ func RegisterCanvasTools(executor *ToolExecutor, canvasHost *CanvasHost, logger *slog.Logger)

+ func RegisterCodebaseTools(executor *ToolExecutor)

+ func RegisterDBTools(executor *ToolExecutor)

+ func RegisterDaemonTools(executor *ToolExecutor, dm *DaemonManager)

+ func RegisterDevUtilTools(executor *ToolExecutor)

+ func RegisterDockerTools(executor *ToolExecutor)

+ func RegisterEnvTools(executor *ToolExecutor)

+ func RegisterGitTools(executor *ToolExecutor)

+ func RegisterIDETools(executor *ToolExecutor)

+ func RegisterMediaTools(executor *ToolExecutor, llmClient *LLMClient, cfg *Config, logger *slog.Logger)

+ func RegisterMultiUserTools(executor *ToolExecutor, um *UserManager)

+ func RegisterOpsTools(executor *ToolExecutor)

+ func RegisterPluginTools(executor *ToolExecutor, pm *PluginManager)

+ func RegisterProductTools(executor *ToolExecutor)

+ func RegisterSessionTools(executor *ToolExecutor, wm *WorkspaceManager)

+ func RegisterSkillCreatorTools(executor *ToolExecutor, registry *skills.Registry, skillsDir string, ...)

+ func RegisterSubagentTools(executor *ToolExecutor, manager *SubagentManager, llmClient *LLMClient, ...)

+ func RegisterSystemTools(executor *ToolExecutor, sandboxRunner *sandbox.Runner, ...)

+ func RegisterTestingTools(executor *ToolExecutor)

+ func ReloadEnvFiles() (int, error)

+ func ResolveProfile(name string, customProfiles map[string]ToolProfile) (allow, deny []string)

+ func SanitizeMemoryContent(content string) string

+ func SaveConfigToFile(cfg *Config, path string) error

+ func SessionIDFromContext(ctx context.Context) string

+ func SplitMessage(text string, maxLen int) []string

+ func StoreKeyring(key, value string) error

+ func StripExternalContentBoundaries(content string) string

+ func StripInternalTags(text string) string

+ func StripReplyTags(text string) string

+ func WrapExternalContent(source, content string) string

+ func WrapMemoriesForPrompt(memories []string) string

+ type APIConfig struct

+ APIKey string

+ BaseURL string

+ Params map[string]any

+ Provider string

+ type AccessConfig struct

+ Admins []string

+ AllowGroupAdmins bool

+ AllowedGroups []string

+ AllowedUsers []string

+ BlockedGroups []string

+ BlockedUsers []string

+ DefaultPolicy AccessPolicy

+ Owners []string

+ PendingMessage string

+ func DefaultAccessConfig() AccessConfig

+ type AccessEntry struct

+ AddedAt time.Time

+ AddedBy string

+ JID string

+ Level AccessLevel

+ Note string

+ type AccessLevel string

+ const AccessAdmin

+ const AccessBlocked

+ const AccessNone

+ const AccessOwner

+ const AccessUnknown

+ const AccessUser

+ func CallerLevelFromContext(ctx context.Context) AccessLevel

+ type AccessManager struct

+ func NewAccessManager(cfg AccessConfig, logger *slog.Logger) *AccessManager

+ func (am *AccessManager) ApplyConfig(cfg AccessConfig)

+ func (am *AccessManager) Block(jid string, blockedBy string)

+ func (am *AccessManager) Check(msg *channels.IncomingMessage) CheckResult

+ func (am *AccessManager) GetLevel(jid string) AccessLevel

+ func (am *AccessManager) Grant(jid string, level AccessLevel, grantedBy string) error

+ func (am *AccessManager) GrantGroup(groupJID string, level AccessLevel, grantedBy string) error

+ func (am *AccessManager) IsAdmin(jid string) bool

+ func (am *AccessManager) IsOwner(jid string) bool

+ func (am *AccessManager) ListGroups() []*AccessEntry

+ func (am *AccessManager) ListUsers() []*AccessEntry

+ func (am *AccessManager) MarkAsked(jid string)

+ func (am *AccessManager) PendingMessage() string

+ func (am *AccessManager) Revoke(jid string, revokedBy string)

+ func (am *AccessManager) Unblock(jid string, unblockedBy string)

+ type AccessPolicy string

+ const PolicyAllow

+ const PolicyAsk

+ const PolicyDeny

+ type ActivationMode string

+ const ActivationAlways

+ const ActivationKeyword

+ const ActivationMention

+ const ActivationReply

+ type AgentConfig struct

+ LLMCallTimeoutSeconds int

+ MaxCompactionAttempts int

+ MaxContinuations int

+ MaxTurns int

+ ReflectionEnabled bool

+ RunTimeoutSeconds int

+ ToolLoop ToolLoopConfig

+ func DefaultAgentConfig() AgentConfig

+ type AgentEvent struct

+ Data any

+ RunID string

+ Seq int64

+ SessionID string

+ Stream string

+ Timestamp time.Time

+ Type string

+ type AgentProfileConfig struct

+ Channels []string

+ Groups []string

+ ID string

+ Instructions string

+ MaxTurns int

+ Model string

+ RunTimeoutSeconds int

+ Skills []string

+ Users []string

+ func (p *AgentProfileConfig) MergeConfig(baseModel, baseInstructions string, baseSkills []string) (model, instructions string, skills []string)

+ type AgentRouter struct

+ func NewAgentRouter(cfg AgentsConfig, logger *slog.Logger) *AgentRouter

+ func (r *AgentRouter) DefaultProfileID() string

+ func (r *AgentRouter) GetProfile(id string) *AgentProfileConfig

+ func (r *AgentRouter) ListProfiles() []string

+ func (r *AgentRouter) Route(channel string, userJID string, groupJID string) *AgentProfileConfig

+ type AgentRun struct

+ func NewAgentRun(llm *LLMClient, executor *ToolExecutor, logger *slog.Logger) *AgentRun

+ func NewAgentRunWithConfig(llm *LLMClient, executor *ToolExecutor, cfg AgentConfig, logger *slog.Logger) *AgentRun

+ func (a *AgentRun) Run(ctx context.Context, systemPrompt string, history []ConversationEntry, ...) (string, error)

+ func (a *AgentRun) RunWithUsage(ctx context.Context, systemPrompt string, history []ConversationEntry, ...) (string, *LLMUsage, error)

+ func (a *AgentRun) SetInterruptChannel(ch <-chan string)

+ func (a *AgentRun) SetLoopDetector(d *ToolLoopDetector)

+ func (a *AgentRun) SetModelOverride(model string)

+ func (a *AgentRun) SetOnBeforeToolExec(fn func())

+ func (a *AgentRun) SetOnToolResult(fn func(name string, result ToolResult))

+ func (a *AgentRun) SetStreamCallback(cb StreamCallback)

+ func (a *AgentRun) SetUsageRecorder(fn func(model string, usage LLMUsage))

+ type AgentsConfig struct

+ Profiles []AgentProfileConfig

+ Routing RoutingConfig

+ type AnnounceCallback func(run *SubagentRun)

+ type ApprovalManager struct

+ func NewApprovalManager(logger *slog.Logger) *ApprovalManager

+ func (m *ApprovalManager) ClearSessionTrust(sessionID string)

+ func (m *ApprovalManager) Create(sessionID, callerJID, toolName string, args map[string]any) (id string, message string)

+ func (m *ApprovalManager) GrantTrust(sessionID, toolName string)

+ func (m *ApprovalManager) IsTrusted(sessionID, toolName string) bool

+ func (m *ApprovalManager) LatestPendingForSession(sessionID string) string

+ func (m *ApprovalManager) PendingCountForSession(sessionID string) int

+ func (m *ApprovalManager) Request(sessionID, callerJID, toolName string, args map[string]any, ...) (bool, error)

+ func (m *ApprovalManager) Resolve(id, sessionID, resolverJID string, approved bool, reason string) bool

+ func (m *ApprovalManager) Wait(id string) (approved bool, err error)

+ type ApprovalResult struct

+ Approved bool

+ Reason string

+ type Assistant struct

+ func New(cfg *Config, logger *slog.Logger) *Assistant

+ func (a *Assistant) AccessManager() *AccessManager

+ func (a *Assistant) ApplyConfigUpdate(newCfg *Config)

+ func (a *Assistant) ChannelManager() *channels.Manager

+ func (a *Assistant) ComposePrompt(session *Session, input string) string

+ func (a *Assistant) Config() *Config

+ func (a *Assistant) ExecuteAgent(ctx context.Context, systemPrompt string, session *Session, userMessage string) string

+ func (a *Assistant) ForceCompactSession(session *Session) (oldLen, newLen int)

+ func (a *Assistant) HandleCommand(msg *channels.IncomingMessage) CommandResult

+ func (a *Assistant) HookManager() *HookManager

+ func (a *Assistant) InjectVaultEnvVars()

+ func (a *Assistant) LLMClient() *LLMClient

+ func (a *Assistant) MediaConfig() MediaConfig

+ func (a *Assistant) MemoryEnabled() bool

+ func (a *Assistant) ProjectManager() *ProjectManager

+ func (a *Assistant) SQLiteMemory() *memory.SQLiteStore

+ func (a *Assistant) Scheduler() *scheduler.Scheduler

+ func (a *Assistant) SchedulerEnabled() bool

+ func (a *Assistant) SessionStore() *SessionStore

+ func (a *Assistant) SetScheduler(s *scheduler.Scheduler)

+ func (a *Assistant) SetVault(v *Vault)

+ func (a *Assistant) SkillRegistry() *skills.Registry

+ func (a *Assistant) Start(ctx context.Context) error

+ func (a *Assistant) Stop()

+ func (a *Assistant) StopActiveRun(workspaceID, sessionID string) bool

+ func (a *Assistant) ToolExecutor() *ToolExecutor

+ func (a *Assistant) UpdateMediaConfig(media MediaConfig)

+ func (a *Assistant) UsageTracker() *UsageTracker

+ func (a *Assistant) Vault() *Vault

+ func (a *Assistant) WorkspaceManager() *WorkspaceManager

+ type AuditRecord struct

+ Allowed bool

+ ArgsSummary string

+ Caller string

+ CreatedAt string

+ ID int64

+ Level string

+ ResultSummary string

+ Tool string

+ type AuditRecordShort struct

+ Allowed bool

+ ArgsSummary string

+ Caller string

+ CreatedAt time.Time

+ ID int64

+ Level string

+ Tool string

+ type BlockStreamConfig struct

+ Enabled bool

+ IdleMs int

+ MaxChars int

+ MinChars int

+ func DefaultBlockStreamConfig() BlockStreamConfig

+ func (c BlockStreamConfig) Effective() BlockStreamConfig

+ type BlockStreamer struct

+ func NewBlockStreamer(cfg BlockStreamConfig, channelMgr *channels.Manager, ...) *BlockStreamer

+ func (bs *BlockStreamer) Finish()

+ func (bs *BlockStreamer) FlushNow()

+ func (bs *BlockStreamer) HasSentBlocks() bool

+ func (bs *BlockStreamer) StreamCallback() StreamCallback

+ type BrowserConfig struct

+ ChromePath string

+ Enabled bool

+ Headless bool

+ MaxPages int

+ TimeoutSeconds int

+ ViewportHeight int

+ ViewportWidth int

+ func DefaultBrowserConfig() BrowserConfig

+ type BrowserManager struct

+ func NewBrowserManager(cfg BrowserConfig, logger *slog.Logger) *BrowserManager

+ func (bm *BrowserManager) ClickElement(ctx context.Context, selector string) error

+ func (bm *BrowserManager) FillInput(ctx context.Context, selector, value string) error

+ func (bm *BrowserManager) GetContent(ctx context.Context) (string, error)

+ func (bm *BrowserManager) Navigate(ctx context.Context, url string) error

+ func (bm *BrowserManager) Screenshot(ctx context.Context) (string, error)

+ func (bm *BrowserManager) Start(ctx context.Context) error

+ func (bm *BrowserManager) Stop()

+ func (bm *BrowserManager) WithSSRFGuard(guard *security.SSRFGuard) *BrowserManager

+ type BudgetConfig struct

+ ActionAtLimit string

+ MonthlyLimitUSD float64

+ WarnAtPercent int

+ func DefaultBudgetConfig() BudgetConfig

+ type Canvas struct

+ CreatedAt time.Time

+ HTML string

+ ID string

+ Port int

+ Title string

+ URL string

+ UpdatedAt time.Time

+ type CanvasConfig struct

+ BasePort int

+ Enabled bool

+ MaxCanvases int

+ TTLMinutes int

+ func DefaultCanvasConfig() CanvasConfig

+ type CanvasHost struct

+ func NewCanvasHost(cfg CanvasConfig, logger *slog.Logger) *CanvasHost

+ func (ch *CanvasHost) CleanupStale() int

+ func (ch *CanvasHost) Create(id, title, html string) (*Canvas, error)

+ func (ch *CanvasHost) List() []*Canvas

+ func (ch *CanvasHost) Stop(id string) error

+ func (ch *CanvasHost) StopAll()

+ func (ch *CanvasHost) Update(id, html string) error

+ type ChannelDiagnostic struct

+ Connected bool

+ LatencyMs int64

+ Name string

+ TestResult string

+ type ChannelHealth struct

+ Connected bool

+ Details map[string]any

+ ErrorCount int

+ LastMessageAt time.Time

+ LatencyMs int64

+ type ChannelsConfig struct

+ Discord discord.Config

+ Slack slack.Config

+ Telegram telegram.Config

+ WhatsApp whatsapp.Config

+ type CheckResult struct

+ Allowed bool

+ Level AccessLevel

+ Reason string

+ ShouldAsk bool

+ type CommandResult struct

+ Handled bool

+ Response string

+ type Config struct

+ API APIConfig

+ Access AccessConfig

+ Agent AgentConfig

+ Agents AgentsConfig

+ BlockStream BlockStreamConfig

+ Budget BudgetConfig

+ Channels ChannelsConfig

+ Database DatabaseConfig

+ Fallback FallbackConfig

+ Gateway GatewayConfig

+ Group GroupConfig

+ Groups GroupsPolicyConfig

+ Heartbeat HeartbeatConfig

+ Hooks HooksConfig

+ Instructions string

+ Language string

+ Logging LoggingConfig

+ MCP MCPConfig

+ Media MediaConfig

+ Memory MemoryConfig

+ Model string

+ Name string

+ Plugins plugins.Config

+ Queue QueueConfig

+ Sandbox sandbox.Config

+ Scheduler SchedulerConfig

+ Security SecurityConfig

+ Skills SkillsConfig

+ Subagents SubagentConfig

+ TTS TTSConfig

+ Team TeamConfig

+ Timezone string

+ TokenBudget TokenBudgetConfig

+ Trigger string

+ WebSearch WebSearchConfig

+ WebUI webui.Config

+ Workspaces WorkspaceConfig

+ func DefaultConfig() *Config

+ func LoadConfigFromFile(path string) (*Config, error)

+ func ParseConfig(data []byte) (*Config, error)

+ type ConfigHealth struct

+ Errors []string

+ Path string

+ Sections []string

+ Valid bool

+ type ConfigWatcher struct

+ func NewConfigWatcher(path string, interval time.Duration, onChange func(*Config), ...) *ConfigWatcher

+ func (w *ConfigWatcher) Start(ctx context.Context)

+ type ConversationEntry struct

+ AssistantResponse string

+ Timestamp time.Time

+ UserMessage string

+ type CooldownConfig struct

+ BillingBackoffHours float64

+ BillingMaxHours float64

+ FailureWindowHours float64

+ InitialBackoffMinutes float64

+ MaxBackoffMinutes float64

+ func DefaultCooldownConfig() CooldownConfig

+ type Daemon struct

+ Command string

+ Error string

+ ExitCode int

+ Label string

+ PID int

+ Port int

+ StartedAt time.Time

+ Status string

+ type DaemonManager struct

+ func NewDaemonManager() *DaemonManager

+ func (dm *DaemonManager) GetLogs(label string, n int, filter string) (string, error)

+ func (dm *DaemonManager) List() []Daemon

+ func (dm *DaemonManager) RestartDaemon(label string) (*Daemon, error)

+ func (dm *DaemonManager) Shutdown()

+ func (dm *DaemonManager) StartDaemon(label, command string, port int, readyPattern string) (*Daemon, error)

+ func (dm *DaemonManager) StopDaemon(label string, force bool) error

+ type DatabaseConfig struct

+ Path string

+ type DatabaseHealth struct

+ Connected bool

+ Error string

+ SizeMB float64

+ Tables map[string]int

+ type DeliveryTarget struct

+ Channel string

+ ChatID string

+ func DeliveryTargetFromContext(ctx context.Context) DeliveryTarget

+ type DiagnosticsResult struct

+ Channels []ChannelDiagnostic

+ Config ConfigHealth

+ Database DatabaseHealth

+ Disk DiskStats

+ Memory MemoryStats

+ RecentErrors []AuditRecordShort

+ type DiskStats struct

+ FreeGB float64

+ TotalGB float64

+ UsedPct float64

+ type EventBus struct

+ func NewEventBus() *EventBus

+ func (eb *EventBus) CleanupRun(runID string)

+ func (eb *EventBus) Emit(event AgentEvent)

+ func (eb *EventBus) EmitDelta(runID, sessionID, content string)

+ func (eb *EventBus) EmitDone(runID, sessionID string, usage any)

+ func (eb *EventBus) EmitError(runID, sessionID, message string)

+ func (eb *EventBus) EmitThinkingDelta(runID, sessionID, content string)

+ func (eb *EventBus) EmitThinkingEnd(runID, sessionID string)

+ func (eb *EventBus) EmitThinkingStart(runID, sessionID string)

+ func (eb *EventBus) EmitToolResult(runID, sessionID, toolName, output string, isError bool)

+ func (eb *EventBus) EmitToolUse(runID, sessionID, toolName string, input any)

+ func (eb *EventBus) Subscribe(fn EventListener) func()

+ func (eb *EventBus) SubscribeRun(runID string, fn EventListener) func()

+ type EventListener func(event AgentEvent)

+ type ExecAnalysisConfig struct

+ Categories map[RiskLevel]RiskCategoryConfig

+ DefaultAction RiskAction

+ Enabled bool

+ SafeBins []string

+ SuspiciousPatterns []string

+ Trust TrustConfig

+ func DefaultExecAnalysisConfig() ExecAnalysisConfig

+ type ExecAnalysisResult struct

+ Action RiskAction

+ IsSuspicious bool

+ MatchedPattern string

+ Reason string

+ Risk RiskLevel

+ SuspiciousMatches []string

+ type ExecAnalyzer struct

+ func NewExecAnalyzer(cfg ExecAnalysisConfig, logger *slog.Logger) *ExecAnalyzer

+ func (a *ExecAnalyzer) Analyze(command string) ExecAnalysisResult

+ func (a *ExecAnalyzer) AnalyzeForRole(command string, role string) ExecAnalysisResult

+ type ExecQueueItem struct

+ Caller string

+ CreatedAt time.Time

+ Description string

+ ID string

+ SessionID string

+ Tool string

+ type ExportedMessage struct

+ Assistant string

+ Timestamp time.Time

+ User string

+ type FailoverReason string

+ const FailoverAuth

+ const FailoverBilling

+ const FailoverFormat

+ const FailoverRateLimit

+ const FailoverServer

+ const FailoverTimeout

+ const FailoverUnknown

+ func ClassifyError(statusCode int, errMsg string) FailoverReason

+ type FallbackConfig struct

+ Chain []ProviderChainEntry

+ InitialBackoffMs int

+ MaxBackoffMs int

+ MaxRetries int

+ Models []string

+ RetryOnStatusCodes []int

+ func DefaultFallbackConfig() FallbackConfig

+ func (f FallbackConfig) Effective() FallbackConfig

+ type FunctionCall struct

+ Arguments string

+ Name string

+ type FunctionDef struct

+ Description string

+ Name string

+ Parameters json.RawMessage

+ type GatewayConfig struct

+ Address string

+ AuthToken string

+ CORSOrigins []string

+ Enabled bool

+ type GroupConfig struct

+ ActivationMode string

+ ContextInjection map[string]string

+ IgnorePatterns []string

+ IntroMessage string

+ MaxParticipants int

+ QuietHours string

+ type GroupManager struct

+ func NewGroupManager(cfg GroupConfig) *GroupManager

+ func (gm *GroupManager) BuildGroupPromptContext(chatID, botName string) string

+ func (gm *GroupManager) GetContextInjection(chatID string) string

+ func (gm *GroupManager) GetIntroMessage(chatID, botName, trigger string) string

+ func (gm *GroupManager) GetParticipants(chatID string) []string

+ func (gm *GroupManager) ShouldRespond(chatID, senderName, messageText, botName, trigger string) (bool, string)

+ func (gm *GroupManager) TrackParticipant(chatID, name string)

+ type GroupPolicy string

+ const GroupPolicyAllowlist

+ const GroupPolicyDisabled

+ const GroupPolicyOpen

+ type GroupPolicyConfig struct

+ Activation ActivationMode

+ AllowedUsers []string

+ ID string

+ Keywords []string

+ MaxParticipants int

+ Name string

+ Policy GroupPolicy

+ QuietHours *QuietHoursConfig

+ Workspace string

+ type GroupPolicyManager struct

+ func NewGroupPolicyManager(cfg GroupsPolicyConfig, logger *slog.Logger) *GroupPolicyManager

+ func (m *GroupPolicyManager) GetGroupConfig(groupJID string) *GroupPolicyConfig

+ func (m *GroupPolicyManager) GetWorkspace(groupJID string) string

+ func (m *GroupPolicyManager) IsBlocked(groupJID string) bool

+ func (m *GroupPolicyManager) IsQuietHours(cfg *GroupPolicyConfig) bool

+ func (m *GroupPolicyManager) ListBlocked() []string

+ func (m *GroupPolicyManager) ListGroups() []string

+ func (m *GroupPolicyManager) ShouldRespond(groupJID, userJID string, content string, isReplyToBot bool, trigger string) bool

+ type GroupsPolicyConfig struct

+ Blocked []string

+ DefaultPolicy GroupPolicy

+ Groups []GroupPolicyConfig

+ type HandlerConfig struct

+ Action string

+ Enabled bool

+ Event string

+ Template string

+ type HealthCheckResult struct

+ Component string

+ LatencyMs int64

+ Message string

+ Status string

+ type Heartbeat struct

+ func NewHeartbeat(cfg HeartbeatConfig, assistant *Assistant, logger *slog.Logger) *Heartbeat

+ func (h *Heartbeat) Start(ctx context.Context)

+ func (h *Heartbeat) Stop()

+ func (h *Heartbeat) UpdateConfig(cfg HeartbeatConfig)

+ type HeartbeatConfig struct

+ ActiveEnd int

+ ActiveStart int

+ Channel string

+ ChatID string

+ Enabled bool

+ Interval time.Duration

+ WorkspaceDir string

+ func DefaultHeartbeatConfig() HeartbeatConfig

+ type HookAction struct

+ Block bool

+ ModifiedArgs map[string]any

+ ModifiedMessage string

+ Reason string

+ type HookEvent string

+ const HookAgentStart

+ const HookAgentStop

+ const HookChannelConnect

+ const HookChannelDisconnect

+ const HookError

+ const HookHeartbeat

+ const HookMemoryRecall

+ const HookMemorySave

+ const HookNotification

+ const HookPostCompact

+ const HookPostToolUse

+ const HookPreCompact

+ const HookPreToolUse

+ const HookSessionEnd

+ const HookSessionStart

+ const HookSubagentStart

+ const HookSubagentStop

+ const HookUserJoin

+ const HookUserLeave

+ const HookUserPromptSubmit

+ type HookHandler func(ctx context.Context, payload HookPayload) HookAction

+ type HookManager struct

+ func NewHookManager(logger *slog.Logger) *HookManager

+ func (hm *HookManager) Dispatch(ctx context.Context, payload HookPayload) HookAction

+ func (hm *HookManager) DispatchAsync(payload HookPayload)

+ func (hm *HookManager) HasHooks(event HookEvent) bool

+ func (hm *HookManager) HookCount() int

+ func (hm *HookManager) ListDetailed() []HookSummary

+ func (hm *HookManager) ListHooks() map[HookEvent][]string

+ func (hm *HookManager) Register(hook *RegisteredHook) error

+ func (hm *HookManager) SetEnabled(name string, enabled bool) bool

+ func (hm *HookManager) Unregister(name string) bool

+ type HookPayload struct

+ Channel string

+ Error error

+ Event HookEvent

+ Extra map[string]any

+ Message string

+ SessionID string

+ ToolArgs map[string]any

+ ToolName string

+ ToolResult string

+ type HookSummary struct

+ Description string

+ Enabled bool

+ Events []HookEvent

+ Name string

+ Priority int

+ Source string

+ type HooksConfig struct

+ Enabled bool

+ Handlers []HandlerConfig

+ Webhooks []WebhookConfig

+ type IDEConfig struct

+ MCPHost string

+ MCPPort int

+ Transport string

+ func DefaultIDEConfig() IDEConfig

+ type IndexConfig struct

+ Auto bool

+ ChunkMaxTokens int

+ type LLMClient struct

+ func NewLLMClient(cfg *Config, logger *slog.Logger) *LLMClient

+ func (c *LLMClient) Complete(ctx context.Context, systemPrompt string, history []ConversationEntry, ...) (string, error)

+ func (c *LLMClient) CompleteWithFallback(ctx context.Context, messages []chatMessage, tools []ToolDefinition) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithFallbackUsingModel(ctx context.Context, modelOverride string, messages []chatMessage, ...) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithTools(ctx context.Context, messages []chatMessage, tools []ToolDefinition) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithToolsStream(ctx context.Context, messages []chatMessage, tools []ToolDefinition, ...) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithToolsStreamUsingModel(ctx context.Context, modelOverride string, messages []chatMessage, ...) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithToolsUsingModel(ctx context.Context, modelOverride string, messages []chatMessage, ...) (*LLMResponse, error)

+ func (c *LLMClient) CompleteWithVision(ctx context.Context, ...) (string, error)

+ func (c *LLMClient) Provider() string

+ func (c *LLMClient) TranscribeAudio(ctx context.Context, audioData []byte, filename, model string, ...) (string, error)

+ type LLMErrorKind int

+ const LLMErrorAuth

+ const LLMErrorBadRequest

+ const LLMErrorBilling

+ const LLMErrorContext

+ const LLMErrorFatal

+ const LLMErrorOverloaded

+ const LLMErrorRateLimit

+ const LLMErrorRetryable

+ const LLMErrorTimeout

+ func (k LLMErrorKind) IsRetryableKind() bool

+ func (k LLMErrorKind) String() string

+ type LLMResponse struct

+ Content string

+ FinishReason string

+ ModelUsed string

+ ToolCalls []ToolCall

+ Usage LLMUsage

+ type LLMUsage struct

+ CompletionTokens int

+ PromptTokens int

+ TotalTokens int

+ type Lane struct

+ MaxConcurrent int

+ Name string

+ func NewLane(name string, maxConcurrent int) *Lane

+ func (l *Lane) ActiveCount() int

+ func (l *Lane) Close()

+ func (l *Lane) Enqueue(ctx context.Context, task LaneTask) error

+ func (l *Lane) IsBusy() bool

+ func (l *Lane) QueueLen() int

+ type LaneConfig struct

+ CronMax int

+ GlobalMax int

+ SessionMax int

+ SubagentMax int

+ func DefaultLaneConfig() LaneConfig

+ type LaneManager struct

+ func NewLaneManager(config LaneConfig, logger *slog.Logger) *LaneManager

+ func (lm *LaneManager) CronLane() *Lane

+ func (lm *LaneManager) GetLane(name string) *Lane

+ func (lm *LaneManager) GlobalLane() *Lane

+ func (lm *LaneManager) SessionLane(sessionID string) *Lane

+ func (lm *LaneManager) SubagentLane() *Lane

+ type LaneTask struct

+ Fn func(ctx context.Context) error

+ ID string

+ Priority int

+ type LoggingConfig struct

+ Format string

+ Level string

+ type LoopDetectionResult struct

+ Message string

+ Pattern string

+ Severity LoopSeverity

+ Streak int

+ type LoopSeverity int

+ const LoopBreaker

+ const LoopCritical

+ const LoopNone

+ const LoopWarning

+ type MCPConfig struct

+ Enabled bool

+ Servers []ManagedMCPServerConfig

+ func DefaultMCPConfig() MCPConfig

+ type MCPManager struct

+ func NewMCPManager(cfg MCPConfig, db *sql.DB, logger *slog.Logger) *MCPManager

+ func (m *MCPManager) AddServer(cfg ManagedMCPServerConfig) error

+ func (m *MCPManager) GetConfig() MCPConfig

+ func (m *MCPManager) GetServer(name string) *MCPServerInfo

+ func (m *MCPManager) ListServers() []MCPServerInfo

+ func (m *MCPManager) LoadFromDB() error

+ func (m *MCPManager) RefreshStatus(ctx context.Context)

+ func (m *MCPManager) Reload(cfg MCPConfig)

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

+ func (m *MCPManager) SetEnabled(name string, enabled bool) error

+ func (m *MCPManager) TestServer(ctx context.Context, name string) (*MCPServerStatus, error)

+ func (m *MCPManager) UpdateServer(name string, cfg ManagedMCPServerConfig) error

+ type MCPServerConfig struct

+ Args []string

+ Command string

+ Env map[string]string

+ Name string

+ Transport string

+ URL string

+ type MCPServerInfo struct

+ Config ManagedMCPServerConfig

+ Status MCPServerStatus

+ type MCPServerStatus struct

+ Connected bool

+ Error string

+ LastChecked time.Time

+ Name string

+ Tools []string

+ type MCPType string

+ const MCPTypeHTTP

+ const MCPTypeSSE

+ const MCPTypeStdio

+ const MCPTypeWebSocket

+ type MaintenanceManager struct

+ func NewMaintenanceManager(db *sql.DB, logger *slog.Logger) *MaintenanceManager

+ func (m *MaintenanceManager) Get() *MaintenanceMode

+ func (m *MaintenanceManager) IsEnabled() bool

+ func (m *MaintenanceManager) Load() error

+ func (m *MaintenanceManager) Set(enabled bool, message, setBy string) error

+ type MaintenanceMode struct

+ Enabled bool

+ Message string

+ SetAt time.Time

+ SetBy string

+ type ManagedMCPServerConfig struct

+ Args []string

+ AutoStart bool

+ Command string

+ Description string

+ Enabled bool

+ Env map[string]string

+ Headers map[string]string

+ Name string

+ Timeout int

+ Type MCPType

+ URL string

+ type MediaConfig struct

+ MaxAudioSize int64

+ MaxImageSize int64

+ TranscriptionAPIKey string

+ TranscriptionBaseURL string

+ TranscriptionEnabled bool

+ TranscriptionLanguage string

+ TranscriptionModel string

+ VisionDetail string

+ VisionEnabled bool

+ VisionModel string

+ func DefaultMediaConfig() MediaConfig

+ func (m *MediaConfig) ResolveForProvider(provider, baseURL string)

+ func (m MediaConfig) Effective() MediaConfig

+ type MemoryConfig struct

+ CompressionStrategy string

+ Embedding memory.EmbeddingConfig

+ Index IndexConfig

+ MaxMessages int

+ Path string

+ Search SearchConfig

+ SessionMemory SessionMemoryConfig

+ Type string

+ type MemoryStats struct

+ AllocMB float64

+ NumGC uint32

+ SysMB float64

+ TotalAllocMB float64

+ type MessageQueue struct

+ func NewMessageQueue(debounceMs, maxPending int, onDrain OnDrainFunc, logger *slog.Logger) *MessageQueue

+ func (q *MessageQueue) CombineMessages(msgs []*channels.IncomingMessage) string

+ func (q *MessageQueue) Drain(sessionID string) []*channels.IncomingMessage

+ func (q *MessageQueue) Enqueue(sessionID string, msg *channels.IncomingMessage) bool

+ func (q *MessageQueue) IsProcessing(sessionID string) bool

+ func (q *MessageQueue) SetProcessing(sessionID string, active bool)

+ func (q *MessageQueue) StuckSessions(maxAge time.Duration) []string

+ func (q *MessageQueue) TrySetProcessing(sessionID string) bool

+ type MetricsResult struct

+ ByModel map[string]MetricsTotals

+ EndTime time.Time

+ Period string

+ StartTime time.Time

+ TopUsers []UserUsage

+ Total MetricsTotals

+ type MetricsTotals struct

+ CompletionTokens int64

+ EstimatedCostUSD float64

+ PromptTokens int64

+ Requests int64

+ TotalTokens int64

+ type ModelCooldown struct

+ ErrorCount int

+ LastError time.Time

+ Model string

+ Reason FailoverReason

+ Until time.Time

+ type ModelCost struct

+ InputPer1M float64

+ OutputPer1M float64

+ type ModelFailoverManager struct

+ func NewModelFailoverManager(config ModelFallbackConfig, logger *slog.Logger) *ModelFailoverManager

+ func (m *ModelFailoverManager) GetCooldownStatus() map[string]*ModelCooldown

+ func (m *ModelFailoverManager) ReportFailure(model string, statusCode int, errMsg string) FailoverReason

+ func (m *ModelFailoverManager) ReportSuccess(model string)

+ func (m *ModelFailoverManager) SelectModel() (model string, isPrimary bool)

+ type ModelFallbackConfig struct

+ Cooldowns CooldownConfig

+ Fallbacks []string

+ Primary string

+ type OnDrainFunc func(sessionID string, msgs []*channels.IncomingMessage)

+ type PairingManager struct

+ func NewPairingManager(db *sql.DB, accessMgr *AccessManager, wsMgr *WorkspaceManager, ...) *PairingManager

+ func (pm *PairingManager) ApproveRequest(requestID, approvedBy string) error

+ func (pm *PairingManager) CreateRequest(tokenID, userJID, userName string) (*PairingRequest, error)

+ func (pm *PairingManager) DenyRequest(requestID, deniedBy, reason string) error

+ func (pm *PairingManager) GenerateToken(createdBy string, opts TokenOptions) (*PairingToken, error)

+ func (pm *PairingManager) GetTokenByIDOrPrefix(idOrPrefix string) (*PairingToken, error)

+ func (pm *PairingManager) ListPendingRequests() ([]*PairingRequest, error)

+ func (pm *PairingManager) ListTokens(includeRevoked bool) ([]*PairingToken, error)

+ func (pm *PairingManager) Load() error

+ func (pm *PairingManager) ProcessTokenRedemption(tokenStr, userJID, userName string) (bool, string, error)

+ func (pm *PairingManager) RevokeToken(tokenID, revokedBy string) error

+ func (pm *PairingManager) ValidateToken(token string) (*PairingToken, error)

+ type PairingRequest struct

+ CreatedAt time.Time

+ ID string

+ ReviewedAt *time.Time

+ ReviewedBy string

+ Status string

+ TokenID string

+ TokenNote string

+ TokenRole TokenRole

+ UserJID string

+ UserName string

+ type PairingToken struct

+ AutoApprove bool

+ CreatedAt time.Time

+ CreatedBy string

+ ExpiresAt *time.Time

+ ID string

+ MaxUses int

+ Note string

+ Revoked bool

+ RevokedAt *time.Time

+ RevokedBy string

+ Role TokenRole

+ Token string

+ UseCount int

+ WorkspaceID string

+ func (t *PairingToken) CanUse() bool

+ func (t *PairingToken) IsExpired() bool

+ type PendingApproval struct

+ Args map[string]any

+ CallerJID string

+ CreatedAt time.Time

+ Description string

+ ID string

+ Result chan ApprovalResult

+ SessionID string

+ ToolName string

+ type Plugin struct

+ Author string

+ Config map[string]any

+ Description string

+ Enabled bool

+ Name string

+ Tools []PluginTool

+ Version string

+ Webhooks []WebhookDef

+ func GitHubPlugin(token string) *Plugin

+ func JiraPlugin(baseURL, token string) *Plugin

+ func SentryPlugin(dsn, token string) *Plugin

+ type PluginManager struct

+ func NewPluginManager() *PluginManager

+ func (pm *PluginManager) Disable(name string) error

+ func (pm *PluginManager) Enable(name string) error

+ func (pm *PluginManager) Get(name string) (*Plugin, bool)

+ func (pm *PluginManager) Install(p *Plugin) error

+ func (pm *PluginManager) List() []*Plugin

+ func (pm *PluginManager) Uninstall(name string) error

+ type PluginTool struct

+ Description string

+ Endpoint string

+ Headers map[string]string

+ Method string

+ Name string

+ Parameters map[string]any

+ type ProfileChecker struct

+ func NewProfileChecker(allow, deny []string, allTools []string) *ProfileChecker

+ func (pc *ProfileChecker) Check(toolName string) (allowed bool, reason string)

+ func (pc *ProfileChecker) IsAllowed(toolName string) bool

+ func (pc *ProfileChecker) IsDenied(toolName string) bool

+ type ProgressSender func(ctx context.Context, message string)

+ func ProgressSenderFromContext(ctx context.Context) ProgressSender

+ type Project struct

+ BuildCmd string

+ DeployCmd string

+ DockerCompose string

+ EnvFile string

+ Framework string

+ GitRemote string

+ ID string

+ Language string

+ LintCmd string

+ MCPServers []MCPServerConfig

+ Name string

+ RootPath string

+ StartCmd string

+ TestCmd string

+ type ProjectManager struct

+ func NewProjectManager(dataDir string) *ProjectManager

+ func (pm *ProjectManager) Activate(sessionKey, projectID string) error

+ func (pm *ProjectManager) ActiveProject(sessionKey string) *Project

+ func (pm *ProjectManager) FindByPath(path string) *Project

+ func (pm *ProjectManager) Get(id string) *Project

+ func (pm *ProjectManager) List() []*Project

+ func (pm *ProjectManager) Register(p *Project) error

+ func (pm *ProjectManager) Remove(id string) error

+ func (pm *ProjectManager) ScanDirectory(root string) ([]*Project, error)

+ type ProjectProviderAdapter struct

+ func NewProjectProviderAdapter(pm *ProjectManager) *ProjectProviderAdapter

+ func (a *ProjectProviderAdapter) Activate(sessionKey, projectID string) error

+ func (a *ProjectProviderAdapter) ActiveProject(sessionKey string) *skills.ProjectInfo

+ func (a *ProjectProviderAdapter) Get(id string) *skills.ProjectInfo

+ func (a *ProjectProviderAdapter) List() []*skills.ProjectInfo

+ func (a *ProjectProviderAdapter) Register(p *skills.ProjectInfo) error

+ func (a *ProjectProviderAdapter) Remove(id string) error

+ func (a *ProjectProviderAdapter) ScanDirectory(root string) ([]*skills.ProjectInfo, error)

+ type PromptComposer struct

+ func NewPromptComposer(config *Config) *PromptComposer

+ func (p *PromptComposer) Compose(session *Session, input string) string

+ func (p *PromptComposer) ComposeMinimal() string

+ func (p *PromptComposer) SetMemoryStore(store *memory.FileStore)

+ func (p *PromptComposer) SetSQLiteMemory(store *memory.SQLiteStore)

+ func (p *PromptComposer) SetSkillGetter(getter func(name string) (interface{ ... }, bool))

+ func (p *PromptComposer) SetSubagentMode(isSubagent bool)

+ type PromptLayer int

+ const LayerBootstrap

+ const LayerBusiness

+ const LayerConversation

+ const LayerCore

+ const LayerIdentity

+ const LayerMemory

+ const LayerRuntime

+ const LayerSafety

+ const LayerSkills

+ const LayerTemporal

+ const LayerThinking

+ type ProviderChainEntry struct

+ APIKey string

+ BaseURL string

+ Model string

+ Provider string

+ type QueueConfig struct

+ ByChannel map[string]QueueMode

+ DebounceMs int

+ DefaultMode QueueMode

+ DropPolicy QueueDropPolicy

+ MaxPending int

+ type QueueDropPolicy string

+ const DropNew

+ const DropOld

+ const DropSummarize

+ type QueueMode string

+ const QueueModeCollect

+ const QueueModeFollowup

+ const QueueModeInterrupt

+ const QueueModeSteer

+ const QueueModeSteerBacklog

+ func EffectiveQueueMode(qc QueueConfig, channelName string) QueueMode

+ func ParseQueueMode(s string) (QueueMode, bool)

+ type QuietHoursConfig struct

+ End string

+ Start string

+ Timezone string

+ type RegisteredHook struct

+ Description string

+ Enabled bool

+ Events []HookEvent

+ Handler HookHandler

+ Name string

+ Priority int

+ Source string

+ type ResolvedWorkspace struct

+ Session *Session

+ SessionStore *SessionStore

+ Workspace *Workspace

+ type RiskAction string

+ const ActionAllow

+ const ActionAllowLog

+ const ActionDeny

+ const ActionRequireApproval

+ type RiskCategoryConfig struct

+ Action RiskAction

+ Message string

+ Notify []string

+ Patterns []string

+ type RiskLevel string

+ const RiskBlocked

+ const RiskDangerous

+ const RiskModerate

+ const RiskSafe

+ type RoutingConfig struct

+ Default string

+ type SQLiteAuditLogger struct

+ func NewSQLiteAuditLogger(db *sql.DB, logger *slog.Logger) *SQLiteAuditLogger

+ func (a *SQLiteAuditLogger) Close()

+ func (a *SQLiteAuditLogger) Count() int

+ func (a *SQLiteAuditLogger) Log(toolName, caller, level string, allowed bool, ...)

+ func (a *SQLiteAuditLogger) Recent(n int) []string

+ func (a *SQLiteAuditLogger) RecentRecords(n int) []AuditRecord

+ type SQLiteSessionPersistence struct

+ func NewSQLiteSessionPersistence(db *sql.DB, logger *slog.Logger) *SQLiteSessionPersistence

+ func (p *SQLiteSessionPersistence) Close() error

+ func (p *SQLiteSessionPersistence) DeleteSession(sessionID string) error

+ func (p *SQLiteSessionPersistence) LoadAll() (map[string]*SessionData, error)

+ func (p *SQLiteSessionPersistence) LoadSession(sessionID string) ([]ConversationEntry, []string, error)

+ func (p *SQLiteSessionPersistence) Rotate(sessionID string, maxLines int) error

+ func (p *SQLiteSessionPersistence) SaveEntry(sessionID string, entry ConversationEntry) error

+ func (p *SQLiteSessionPersistence) SaveFacts(sessionID string, facts []string) error

+ func (p *SQLiteSessionPersistence) SaveMeta(sessionID, channel, chatID string, config SessionConfig, activeSkills []string) error

+ type SchedulerConfig struct

+ Enabled bool

+ Storage string

+ type SchedulerStats struct

+ Enabled bool

+ Jobs int

+ NextRun string

+ Running int

+ type SearchConfig struct

+ HybridWeightBM25 float64

+ HybridWeightVector float64

+ MaxResults int

+ MinScore float64

+ type SecurityConfig struct

+ EnablePIIDetection bool

+ EnableURLValidation bool

+ ExecAnalysis ExecAnalysisConfig

+ MaxInputLength int

+ RateLimit int

+ SSRF security.SSRFConfig

+ ToolExecutor ToolExecutorConfig

+ ToolGuard ToolGuardConfig

+ type Session struct

+ Channel string

+ ChatID string

+ CreatedAt time.Time

+ ID string

+ func (s *Session) AddFact(fact string)

+ func (s *Session) AddMessage(userMsg, assistantResp string)

+ func (s *Session) AddTokenUsage(promptTokens, completionTokens int)

+ func (s *Session) ClearFacts()

+ func (s *Session) ClearHistory()

+ func (s *Session) CompactHistory(summary string, keepRecent int) []ConversationEntry

+ func (s *Session) GetActiveSkills() []string

+ func (s *Session) GetConfig() SessionConfig

+ func (s *Session) GetFacts() []string

+ func (s *Session) GetThinkingLevel() string

+ func (s *Session) GetTokenUsage() (promptTokens, completionTokens, requests int)

+ func (s *Session) HistoryLen() int

+ func (s *Session) LastActiveAt() time.Time

+ func (s *Session) RecentHistory(maxEntries int) []ConversationEntry

+ func (s *Session) ResetTokenUsage()

+ func (s *Session) SetActiveSkills(skills []string)

+ func (s *Session) SetConfig(cfg SessionConfig)

+ func (s *Session) SetThinkingLevel(level string)

+ type SessionConfig struct

+ BusinessContext string

+ Language string

+ MaxTokens int

+ Model string

+ ThinkingLevel string

+ Trigger string

+ Verbose bool

+ type SessionData struct

+ ActiveSkills []string

+ Channel string

+ ChatID string

+ Config SessionConfig

+ Facts []string

+ History []ConversationEntry

+ ID string

+ type SessionExport struct

+ Channel string

+ ChatID string

+ Config SessionConfig

+ CreatedAt time.Time

+ Facts []string

+ ID string

+ Messages []ExportedMessage

+ type SessionInfo struct

+ WorkspaceID string

+ type SessionKey struct

+ Branch string

+ Channel string

+ ChatID string

+ func ParseSessionKey(s string) SessionKey

+ func (sk SessionKey) Hash() string

+ func (sk SessionKey) String() string

+ type SessionMemoryConfig struct

+ Enabled bool

+ Messages int

+ type SessionMeta struct

+ Channel string

+ ChatID string

+ CreatedAt time.Time

+ ID string

+ LastActiveAt time.Time

+ MessageCount int

+ type SessionPersistence struct

+ func NewSessionPersistence(dir string, logger *slog.Logger) (*SessionPersistence, error)

+ func (p *SessionPersistence) Close() error

+ func (p *SessionPersistence) DeleteSession(sessionID string) error

+ func (p *SessionPersistence) LoadAll() (map[string]*SessionData, error)

+ func (p *SessionPersistence) LoadSession(sessionID string) ([]ConversationEntry, []string, error)

+ func (p *SessionPersistence) Rotate(sessionID string, maxLines int) error

+ func (p *SessionPersistence) SaveEntry(sessionID string, entry ConversationEntry) error

+ func (p *SessionPersistence) SaveFacts(sessionID string, facts []string) error

+ func (p *SessionPersistence) SaveMeta(sessionID, channel, chatID string, config SessionConfig, activeSkills []string) error

+ type SessionPersister interface

+ Close func() error

+ DeleteSession func(sessionID string) error

+ LoadAll func() (map[string]*SessionData, error)

+ LoadSession func(sessionID string) ([]ConversationEntry, []string, error)

+ Rotate func(sessionID string, maxLines int) error

+ SaveEntry func(sessionID string, entry ConversationEntry) error

+ SaveFacts func(sessionID string, facts []string) error

+ SaveMeta func(sessionID, channel, chatID string, config SessionConfig, activeSkills []string) error

+ type SessionStats struct

+ Active int

+ Total int

+ WithHistory int

+ type SessionStore struct

+ func NewSessionStore(logger *slog.Logger) *SessionStore

+ func (ss *SessionStore) Count() int

+ func (ss *SessionStore) Delete(channel, chatID string) bool

+ func (ss *SessionStore) DeleteByID(id string) bool

+ func (ss *SessionStore) Export(id string) *SessionExport

+ func (ss *SessionStore) Get(channel, chatID string) *Session

+ func (ss *SessionStore) GetByID(id string) *Session

+ func (ss *SessionStore) GetOrCreate(channel, chatID string) *Session

+ func (ss *SessionStore) ListSessions() []SessionMeta

+ func (ss *SessionStore) Prune() int

+ func (ss *SessionStore) RenameSession(oldID, newChannel, newChatID string) bool

+ func (ss *SessionStore) SetPersistence(p SessionPersister)

+ func (ss *SessionStore) StartPruner(ctx context.Context)

+ type SessionUsage struct

+ CompletionTokens int64

+ EstimatedCostUSD float64

+ FirstRequestAt time.Time

+ LastRequestAt time.Time

+ PromptTokens int64

+ Requests int64

+ TotalTokens int64

+ type SharedMemory struct

+ Author string

+ Key string

+ Tags []string

+ UpdatedAt time.Time

+ Value string

+ type SkillsConfig struct

+ Builtin []string

+ ClawdHubDirs []string

+ Installed []string

+ type SpawnParams struct

+ Label string

+ Model string

+ OriginChannel string

+ OriginThreadID string

+ OriginTo string

+ ParentSessionID string

+ Task string

+ TimeoutSeconds int

+ type StartupCheckResult struct

+ Message string

+ Name string

+ Required bool

+ Status string

+ type StartupReport struct

+ Healthy bool

+ Results []StartupCheckResult

+ type StartupVerifier struct

+ func NewStartupVerifier(cfg *Config, vault *Vault, logger *slog.Logger) *StartupVerifier

+ func (sv *StartupVerifier) PrintReport(report *StartupReport)

+ func (sv *StartupVerifier) RunAll() *StartupReport

+ type StreamCallback func(chunk string)

+ type SubagentConfig struct

+ DeniedTools []string

+ Enabled bool

+ MaxConcurrent int

+ MaxTurns int

+ Model string

+ TimeoutSeconds int

+ func DefaultSubagentConfig() SubagentConfig

+ type SubagentManager struct

+ func NewSubagentManager(cfg SubagentConfig, logger *slog.Logger) *SubagentManager

+ func (m *SubagentManager) ActiveCount() int

+ func (m *SubagentManager) Cleanup(maxAge time.Duration) int

+ func (m *SubagentManager) Get(runID string) (*SubagentRun, bool)

+ func (m *SubagentManager) List() []*SubagentRun

+ func (m *SubagentManager) PruneOldRuns(days int) int

+ func (m *SubagentManager) SetAnnounceCallback(cb AnnounceCallback)

+ func (m *SubagentManager) SetDB(db *sql.DB)

+ func (m *SubagentManager) Spawn(parentCtx context.Context, params SpawnParams, llmClient *LLMClient, ...) (*SubagentRun, error)

+ func (m *SubagentManager) Stop(runID string) error

+ func (m *SubagentManager) Wait(ctx context.Context, runID string) (*SubagentRun, error)

+ type SubagentRun struct

+ CompletedAt time.Time

+ Duration time.Duration

+ Error string

+ ID string

+ Label string

+ Model string

+ OriginChannel string

+ OriginThreadID string

+ OriginTo string

+ ParentSessionID string

+ Result string

+ StartedAt time.Time

+ Status SubagentStatus

+ Task string

+ TokensUsed int

+ type SubagentStatus string

+ const SubagentStatusCompleted

+ const SubagentStatusFailed

+ const SubagentStatusRunning

+ const SubagentStatusTimeout

+ type SystemCommands struct

+ func NewSystemCommands(a *Assistant, configPath string, maintenanceMgr *MaintenanceManager) *SystemCommands

+ func (t *SystemCommands) ChannelsCommand(args []string) string

+ func (t *SystemCommands) DiagnosticsCommand(full bool) string

+ func (t *SystemCommands) ExecQueueCommand() string

+ func (t *SystemCommands) HealthCommand() string

+ func (t *SystemCommands) LogsCommand(args []string) string

+ func (t *SystemCommands) MaintenanceCommand(args []string, setBy string) string

+ func (t *SystemCommands) MetricsCommand(args []string) string

+ func (t *SystemCommands) ReloadCommand(args []string) string

+ func (t *SystemCommands) StatusCommand(jsonOutput bool) string

+ type SystemStatus struct

+ Channels map[string]ChannelHealth

+ GoRoutines int

+ Maintenance *MaintenanceMode

+ MemoryMB float64

+ Scheduler SchedulerStats

+ Sessions SessionStats

+ Skills int

+ Uptime string

+ UptimeSeconds int64

+ Version string

+ type TTSConfig struct

+ AutoMode string

+ EdgeVoice string

+ Enabled bool

+ Model string

+ Provider string

+ Voice string

+ type TailscaleConfig struct

+ Enabled bool

+ Funnel bool

+ Hostname string

+ Port int

+ Serve bool

+ type TailscaleManager struct

+ func NewTailscaleManager(cfg TailscaleConfig, logger *slog.Logger) *TailscaleManager

+ func (tm *TailscaleManager) Start(ctx context.Context) error

+ func (tm *TailscaleManager) Status() map[string]any

+ func (tm *TailscaleManager) Stop()

+ func (tm *TailscaleManager) URL() string

+ type TeamConfig struct

+ AuditLog bool

+ DefaultRole string

+ Enabled bool

+ MaxUsers int

+ SharedMemory bool

+ func DefaultTeamConfig() TeamConfig

+ type TeamUser struct

+ Active bool

+ CreatedAt time.Time

+ Email string

+ ID string

+ LastSeen time.Time

+ Name string

+ Role UserRole

+ type TokenBudgetConfig struct

+ BootstrapMaxChars int

+ History int

+ Memory int

+ Reserved int

+ Skills int

+ System int

+ Tools int

+ Total int

+ type TokenOptions struct

+ AutoApprove bool

+ ExpiresIn time.Duration

+ MaxUses int

+ Note string

+ Role TokenRole

+ WorkspaceID string

+ type TokenRole string

+ const TokenRoleAdmin

+ const TokenRoleUser

+ type ToolCall struct

+ Function FunctionCall

+ ID string

+ Type string

+ type ToolCheckResult struct

+ Allowed bool

+ Reason string

+ RequiresConfirmation bool

+ type ToolDefinition struct

+ Function FunctionDef

+ Type string

+ func MakeToolDefinition(name, description string, params map[string]any) ToolDefinition

+ func SkillToolToDefinition(name string, tool skills.Tool) ToolDefinition

+ type ToolExecutor struct

+ func NewToolExecutor(logger *slog.Logger) *ToolExecutor

+ func (e *ToolExecutor) Abort()

+ func (e *ToolExecutor) AbortCh() <-chan struct{}

+ func (e *ToolExecutor) Configure(cfg ToolExecutorConfig)

+ func (e *ToolExecutor) Execute(ctx context.Context, calls []ToolCall) []ToolResult

+ func (e *ToolExecutor) Guard() *ToolGuard

+ func (e *ToolExecutor) HasTool(name string) bool

+ func (e *ToolExecutor) IsAborted() bool

+ func (e *ToolExecutor) Register(def ToolDefinition, handler ToolHandlerFunc)

+ func (e *ToolExecutor) RegisterHook(hook *ToolHook)

+ func (e *ToolExecutor) RegisterSkillTools(skill skills.Skill)

+ func (e *ToolExecutor) ResetAbort()

+ func (e *ToolExecutor) SessionContext() string

+ func (e *ToolExecutor) SetCallerContext(level AccessLevel, jid string)

+ func (e *ToolExecutor) SetConfirmationRequester(...)

+ func (e *ToolExecutor) SetGuard(guard *ToolGuard)

+ func (e *ToolExecutor) SetSessionContext(sessionID string)

+ func (e *ToolExecutor) ToolNames() []string

+ func (e *ToolExecutor) Tools() []ToolDefinition

+ func (e *ToolExecutor) UpdateGuardConfig(cfg ToolGuardConfig)

+ type ToolExecutorConfig struct

+ BashTimeoutSeconds int

+ DefaultTimeoutSeconds int

+ MaxParallel int

+ Parallel bool

+ type ToolGuard struct

+ func NewToolGuard(cfg ToolGuardConfig, logger *slog.Logger) *ToolGuard

+ func (g *ToolGuard) AuditLog(toolName string, callerJID string, callerLevel AccessLevel, ...)

+ func (g *ToolGuard) Check(toolName string, callerLevel AccessLevel, args map[string]any) ToolCheckResult

+ func (g *ToolGuard) CheckWithProfile(toolName string, callerLevel AccessLevel, args map[string]any, ...) ToolCheckResult

+ func (g *ToolGuard) Close()

+ func (g *ToolGuard) GetActiveProfile() *ToolProfile

+ func (g *ToolGuard) GetAllToolNames() []string

+ func (g *ToolGuard) SQLiteAudit() *SQLiteAuditLogger

+ func (g *ToolGuard) SetSQLiteAudit(a *SQLiteAuditLogger)

+ func (g *ToolGuard) UpdateConfig(cfg ToolGuardConfig)

+ type ToolGuardConfig struct

+ AllowDestructive bool

+ AllowReboot bool

+ AllowSudo bool

+ AuditLogPath string

+ AutoApprove []string

+ BlockSudo bool

+ CustomProfiles map[string]ToolProfile

+ DangerousCommands []string

+ Enabled bool

+ Profile string

+ ProtectedPaths []string

+ RequireConfirmation []string

+ SSHAllowedHosts []string

+ ToolPermissions map[string]string

+ func DefaultToolGuardConfig() ToolGuardConfig

+ type ToolHandlerFunc func(ctx context.Context, args map[string]any) (any, error)

+ type ToolHook struct

+ AfterToolCall func(toolName string, args map[string]any, result string, err error)

+ BeforeToolCall func(toolName string, args map[string]any) (modifiedArgs map[string]any, blocked bool, blockReason string)

+ Name string

+ type ToolLoopConfig struct

+ CircuitBreakerThreshold int

+ CriticalThreshold int

+ Enabled bool

+ GlobalCircuitBreaker int

+ HistorySize int

+ WarningThreshold int

+ func DefaultToolLoopConfig() ToolLoopConfig

+ type ToolLoopDetector struct

+ func NewToolLoopDetector(cfg ToolLoopConfig, logger *slog.Logger) *ToolLoopDetector

+ func (d *ToolLoopDetector) RecordAndCheck(toolName string, args map[string]any) LoopDetectionResult

+ func (d *ToolLoopDetector) RecordToolOutcome(output string)

+ func (d *ToolLoopDetector) Reset()

+ type ToolPermission string

+ const PermAdmin

+ const PermOwner

+ const PermPublic

+ const PermUser

+ type ToolProfile struct

+ Allow []string

+ Deny []string

+ Description string

+ Name string

+ func GetProfile(name string, customProfiles map[string]ToolProfile) *ToolProfile

+ func ToolProfileFromContext(ctx context.Context) *ToolProfile

+ type ToolResult struct

+ Content string

+ Error error

+ Name string

+ ToolCallID string

+ type TrustConfig struct

+ Admin RiskLevel

+ Owner RiskLevel

+ User RiskLevel

+ type UsageTracker struct

+ func NewUsageTracker(logger *slog.Logger) *UsageTracker

+ func (u *UsageTracker) FormatGlobalUsage() string

+ func (u *UsageTracker) FormatUsage(sessionID string) string

+ func (u *UsageTracker) GetGlobal() *SessionUsage

+ func (u *UsageTracker) GetSession(sessionID string) *SessionUsage

+ func (u *UsageTracker) Record(sessionID, model string, usage LLMUsage)

+ func (u *UsageTracker) ResetSession(sessionID string)

+ type UserManager struct

+ func NewUserManager(config TeamConfig) *UserManager

+ func (um *UserManager) AddUser(user *TeamUser) error

+ func (um *UserManager) CheckPermission(userID string, required UserRole) bool

+ func (um *UserManager) GetSharedMemory(key string) (*SharedMemory, bool)

+ func (um *UserManager) GetUser(id string) (*TeamUser, bool)

+ func (um *UserManager) ListSharedMemory() []*SharedMemory

+ func (um *UserManager) ListUsers() []*TeamUser

+ func (um *UserManager) RemoveUser(id string) error

+ func (um *UserManager) SetSharedMemory(key, value, authorID string, tags []string)

+ type UserRole string

+ const RoleAdmin

+ const RoleOwner

+ const RoleUser

+ const RoleViewer

+ type UserUsage struct

+ CostUSD float64

+ Requests int64

+ SessionID string

+ Tokens int64

+ type Vault struct

+ func NewVault(path string) *Vault

+ func ResolveAPIKey(cfg *Config, logger *slog.Logger) *Vault

+ func (v *Vault) ChangePassword(newPassword string) error

+ func (v *Vault) Create(password string) error

+ func (v *Vault) Delete(name string) error

+ func (v *Vault) Exists() bool

+ func (v *Vault) Get(name string) (string, error)

+ func (v *Vault) IsUnlocked() bool

+ func (v *Vault) Keys() ([]string, error)

+ func (v *Vault) List() []string

+ func (v *Vault) Lock()

+ func (v *Vault) Path() string

+ func (v *Vault) Set(name, value string) error

+ func (v *Vault) Unlock(password string) error

+ type VaultData struct

+ Entries map[string]VaultEntry

+ Salt string

+ Version int

+ type VaultEntry struct

+ Ciphertext string

+ Nonce string

+ type WebSearchConfig struct

+ BraveAPIKey string

+ MaxResults int

+ Provider string

+ type WebhookConfig struct

+ Enabled bool

+ Events []string

+ Headers map[string]string

+ Name string

+ RetryCount int

+ RetryDelayMs int

+ Secret string

+ Timeout int

+ URL string

+ type WebhookDef struct

+ Events []string

+ Headers map[string]string

+ Path string

+ Secret string

+ type WebhookDispatcher struct

+ func NewWebhookDispatcher() *WebhookDispatcher

+ func (wd *WebhookDispatcher) Dispatch(ctx context.Context, event string, payload []byte) error

+ func (wd *WebhookDispatcher) On(event string, handler WebhookHandler)

+ type WebhookHandler func(ctx context.Context, event string, payload []byte) error

+ type WebhookManager struct

+ func NewWebhookManager(cfg WebhooksConfig, hookMgr *HookManager, logger *slog.Logger) *WebhookManager

+ func (wm *WebhookManager) ForwardEvent(payload HookPayload)

+ func (wm *WebhookManager) ListWebhooks() []WebhookConfig

+ func (wm *WebhookManager) Reload(cfg WebhooksConfig)

+ func (wm *WebhookManager) SetWebhookEnabled(name string, enabled bool) bool

+ type WebhookPayload struct

+ Channel string

+ Error string

+ Event string

+ Extra map[string]any

+ Message string

+ SessionID string

+ Timestamp string

+ ToolName string

+ type WebhooksConfig struct

+ Enabled bool

+ Webhooks []WebhookConfig

+ type Workspace struct

+ Active bool

+ CreatedAt time.Time

+ CreatedBy string

+ Description string

+ Groups []string

+ ID string

+ Instructions string

+ Language string

+ MaxMessages int

+ Members []string

+ Model string

+ Name string

+ Skills []string

+ Timezone string

+ TokenBudget *TokenBudgetConfig

+ ToolProfile string

+ Trigger string

+ type WorkspaceConfig struct

+ DefaultWorkspace string

+ Workspaces []Workspace

+ func DefaultWorkspaceConfig() WorkspaceConfig

+ type WorkspaceContainment struct

+ Enabled bool

+ Root string

+ func NewWorkspaceContainment(root string) *WorkspaceContainment

+ func (wc *WorkspaceContainment) AssertNoSymlinkEscape(path string) error

+ func (wc *WorkspaceContainment) AssertSandboxPath(path string) (string, error)

+ type WorkspaceManager struct

+ func NewWorkspaceManager(globalCfg *Config, wsCfg WorkspaceConfig, logger *slog.Logger) *WorkspaceManager

+ func (wm *WorkspaceManager) AssignGroup(groupJID, wsID, assignedBy string) error

+ func (wm *WorkspaceManager) AssignUser(jid, wsID, assignedBy string) error

+ func (wm *WorkspaceManager) Count() int

+ func (wm *WorkspaceManager) Create(ws Workspace, createdBy string) error

+ func (wm *WorkspaceManager) Delete(wsID, deletedBy string) error

+ func (wm *WorkspaceManager) DeleteSessionByID(sessionID string) bool

+ func (wm *WorkspaceManager) ExportSession(id string) *SessionExport

+ func (wm *WorkspaceManager) FindSessionByID(id string) *Session

+ func (wm *WorkspaceManager) Get(wsID string) (*Workspace, bool)

+ func (wm *WorkspaceManager) GetForUser(jid string) (*Workspace, bool)

+ func (wm *WorkspaceManager) GetSessionByID(sessionID string) (*Session, *Workspace)

+ func (wm *WorkspaceManager) List() []*Workspace

+ func (wm *WorkspaceManager) ListAllSessions() []SessionInfo

+ func (wm *WorkspaceManager) Resolve(channel, chatID, senderJID string, isGroup bool) *ResolvedWorkspace

+ func (wm *WorkspaceManager) SessionCount() int

+ func (wm *WorkspaceManager) SetPersistence(p SessionPersister)

+ func (wm *WorkspaceManager) StartPruners(ctx context.Context)

+ func (wm *WorkspaceManager) UnassignUser(jid string)

+ func (wm *WorkspaceManager) Update(wsID string, fn func(ws *Workspace)) error

v1.6.1

Feb 17, 2026

v1.6.0

Feb 17, 2026

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