agent

package

Go to main page

Versions in this module

v0

v0.17.22

Aug 31, 2026

v0.17.21

Aug 29, 2026

Changes in this version

+ const WakeupBatchPrefix

type Agent

+ func (a *Agent) DrainWakeupForREPL() []string

+ func (a *Agent) SetWakeupWakeFn(fn func())

v0.17.20

Aug 29, 2026

Changes in this version

+ const QuerySourceAutoResume

+ const QuerySourceCLI

+ const QuerySourceUnknown

+ const QuerySourceWebUI

type Agent

+ func (a *Agent) ExecuteToolByName(ctx context.Context, name, argsJSON string) (content string, toolErr string)

+ func (a *Agent) GetMaxContextTokensCached() int

+ func (a *Agent) ProcessQueryAs(source, userQuery string) (string, error)

+ func (a *Agent) ProcessQueryWithContinuityAs(source, userQuery string) (string, error)

+ func (a *Agent) QueryGuardOwner() QueryGuardOwner

+ func (a *Agent) TryBeginQueryAs(source string) error

+ type QueryGuardOwner struct

+ Source string

+ StartedAt time.Time

v0.17.19

Aug 24, 2026

v0.17.18

Aug 24, 2026

Changes in this version

+ func DeliverEditDecision(requestID string, decision EditDecision) bool

+ func DeliverShellDecision(requestID string, decisions map[string]bool) bool

type Agent

+ func (a *Agent) GetContinuationNudges() int

+ func (a *Agent) PendingSteerCount() int

+ func (a *Agent) PromptFileAccess(ctx context.Context, toolName, filePath, resolvedPath, mode string) (context.Context, bool)

+ func (a *Agent) RetractLatestDeferredMessage() (string, bool)

+ func (a *Agent) RetractLatestSteer() (string, bool)

+ func (a *Agent) StageSteerInput(text string) error

type AgentMetricsManager

+ func (m *AgentMetricsManager) GetContinuationNudges() int

+ func (m *AgentMetricsManager) RecordContinuationNudges(n int)

+ type ContinuationNudgeStore interface

+ GetContinuationNudges func() int

+ RecordContinuationNudges func(int)

type ConversationState

+ ContinuationNudges int

v0.17.17

Aug 18, 2026

Changes in this version

+ func BuildToolDefinitionsForAgent(a *Agent) []api.Tool

+ func LoadStateRecoverable(sessionID, workingDir string) (*ConversationState, RecoveryReport, error)

+ func RemoveTurnJournal(sessionID, workingDir string) error

type Agent

+ func (a *Agent) ApplyRecoveredState(state *ConversationState) RecoveryReport

+ func (a *Agent) EnsureLocalServer() error

+ func (a *Agent) ForceSaveAndExit(code int)

+ func (a *Agent) IsShutdown() bool

+ func (a *Agent) NoteRecoveredSession()

+ func (a *Agent) PublishEvent(eventType string, data interface{})

+ func (a *Agent) RefreshContextCapFromConfig()

type ConversationState

+ InterruptedAt *time.Time

+ RecoveredFromJournal bool

+ type RecoveryReport struct

+ InterruptedAt *time.Time

+ JournalEvents int

+ JournalReplayed bool

+ Repair RepairReport

+ type RepairReport struct

+ DroppedToolResults int

+ StrippedAssistantToolCalls int

+ func RepairMessageTail(msgs []api.Message) ([]api.Message, RepairReport)

type SessionInfo

+ Interrupted bool

+ type TurnJournal struct

+ func OpenTurnJournal(sessionID, workingDir string) (*TurnJournal, error)

+ func (j *TurnJournal) AppendTurnEvent(ev TurnJournalEvent) error

+ func (j *TurnJournal) CloseTurnJournal() error

+ type TurnJournalEvent struct

+ Base int

+ Checkpoint *TurnCheckpoint

+ Msgs []api.Message

+ Query string

+ TokenTotals *TurnJournalTokens

+ Ts time.Time

+ Type string

+ V int

+ type TurnJournalTokens struct

+ CompletionTokens int

+ PromptTokens int

+ TotalCost float64

+ TotalTokens int

v0.17.16

Aug 2, 2026

Changes in this version

type SkillInfo

+ func LoadSkillInWorkspace(skillID string, config *configuration.Config, workspaceRoot string) (*SkillInfo, error)

v0.17.15

Jul 31, 2026

v0.17.14

Jul 31, 2026

Changes in this version

type Agent

+ func (a *Agent) InjectSemanticRecallWithItems(ctx context.Context, query string, items []RecalledItem)

+ func (a *Agent) LifetimeCtx() context.Context

+ func (a *Agent) TryAutoResume() bool

v0.17.13

Jul 30, 2026

v0.17.12

Jul 30, 2026

v0.17.11

Jul 30, 2026

v0.17.10

Jul 28, 2026

Changes in this version

+ func TestShellApprovalCleanup(requestID string) — darwin/amd64, linux/amd64, windows/amd64

+ func TestShellApprovalRegister(requestID string) chan map[string]bool — darwin/amd64, linux/amd64, windows/amd64

+ func TestShellApprovalRespond(requestID string, decisions map[string]bool) bool — darwin/amd64, linux/amd64, windows/amd64

type Agent

+ func (a *Agent) RespondToShellApproval(requestID string, decisions map[string]bool) bool

+ type BatchSplitResult struct

+ InlineIndices []int

+ OverflowIndices []int

+ func BatchSplit(sizes []int, caps api.VisionCapabilities) BatchSplitResult

type OutputRouter

+ func (r *OutputRouter) FlushExternalWrite()

v0.17.9

Jul 23, 2026

v0.17.8

Jul 23, 2026

v0.17.7

Jul 23, 2026

Changes in this version

+ const MaxChainSubcommandsForBatchPrompt

+ func ChainCacheKey(input string) string

+ func GetEmbeddedSystemPromptForProfile(profile configuration.ContextProfile, provider string, contextWindow int, ...) (string, error)

+ func InjectUserMessageTimestamp(userMessage string) string

+ func InjectUserMessageTimestampAt(userMessage string, at time.Time) string

+ func NewCascadingPasswordPrompter(prompters ...tools.PasswordPrompter) *cascadingPasswordPrompter

+ func NormalizeChain(chain Chain) string

+ func StripUserMessageTimestamp(userMessage string) string

type Agent

+ func (a *Agent) ClassifyFileAccess(ctx context.Context, filePath, resolvedPath, mode string) string

+ func (a *Agent) ClearSecurityAnalysisCache()

+ func (a *Agent) GetContextProfile() configuration.ContextProfile

+ func (a *Agent) GetEffectiveContextCap() int

+ func (a *Agent) InitSubManagersForTest()

+ func (a *Agent) IsCdTargetAllowed(target string) bool

+ func (a *Agent) IsFolderSessionWriteAllowed(absPath string) bool

+ func (a *Agent) IsReadOnlyAllowedFolder(absPath string) bool

+ func (a *Agent) IsUnderWorkspaceRoot(absPath string) bool

+ func (a *Agent) ListAllowedCdTargets() []string

+ func (a *Agent) RemoveSessionAllowedFolder(folder string) error

+ func (a *Agent) SetSessionAllowedFolderMode(folder, mode string)

+ func (a *Agent) SnapshotSessionAllowedFolderModes() map[string]string

+ type AgentMetricsManager struct

+ func NewAgentMetricsManager() *AgentMetricsManager

+ func (m *AgentMetricsManager) AddCost(c float64)

+ func (m *AgentMetricsManager) AddCostEntry(entry CostEntry)

+ func (m *AgentMetricsManager) GetCacheWriteTokens() int

+ func (m *AgentMetricsManager) GetCachedCostSavings() float64

+ func (m *AgentMetricsManager) GetCachedTokens() int

+ func (m *AgentMetricsManager) GetChargedCostTotal() float64

+ func (m *AgentMetricsManager) GetCompletionTokens() int

+ func (m *AgentMetricsManager) GetEstimatedTokenResponses() int

+ func (m *AgentMetricsManager) GetFreeTokens() int

+ func (m *AgentMetricsManager) GetImageTokens() int

+ func (m *AgentMetricsManager) GetLLMCallCount() int

+ func (m *AgentMetricsManager) GetPromptTokens() int

+ func (m *AgentMetricsManager) GetSubscriptionTokens() int

+ func (m *AgentMetricsManager) GetTokenCostTotal() float64

+ func (m *AgentMetricsManager) GetTotalCost() float64

+ func (m *AgentMetricsManager) GetTotalTokens() int

+ func (m *AgentMetricsManager) GetTotalToolCalls() int

+ func (m *AgentMetricsManager) IncrementLLMCallCount()

+ func (m *AgentMetricsManager) IncrementTotalToolCalls()

+ func (m *AgentMetricsManager) SetCacheWriteTokens(n int)

+ func (m *AgentMetricsManager) SetCachedCostSavings(c float64)

+ func (m *AgentMetricsManager) SetCachedTokens(n int)

+ func (m *AgentMetricsManager) SetChargedCostTotal(v float64)

+ func (m *AgentMetricsManager) SetCompletionTokens(n int)

+ func (m *AgentMetricsManager) SetEstimatedTokenResponses(n int)

+ func (m *AgentMetricsManager) SetFreeTokens(v int)

+ func (m *AgentMetricsManager) SetImageTokens(n int)

+ func (m *AgentMetricsManager) SetLLMCallCount(n int)

+ func (m *AgentMetricsManager) SetPromptTokens(n int)

+ func (m *AgentMetricsManager) SetSubscriptionTokens(v int)

+ func (m *AgentMetricsManager) SetTokenCostTotal(v float64)

+ func (m *AgentMetricsManager) SetTotalCost(c float64)

+ func (m *AgentMetricsManager) SetTotalTokens(n int)

+ func (m *AgentMetricsManager) SetTotalToolCalls(n int)

+ type AgentPersonaManager struct

+ func NewAgentPersonaManager() *AgentPersonaManager

+ func (p *AgentPersonaManager) AddTaskAction(action TaskAction)

+ func (p *AgentPersonaManager) GetActivePersona() string

+ func (p *AgentPersonaManager) GetActiveSkills() []string

+ func (p *AgentPersonaManager) GetTaskActions() []TaskAction

+ func (p *AgentPersonaManager) GetTaskActionsMutex() *sync.RWMutex

+ func (p *AgentPersonaManager) IsFalseStopDetectionEnabled() bool

+ func (p *AgentPersonaManager) IsToolCallGuidanceAdded() bool

+ func (p *AgentPersonaManager) SetActivePersona(persona string)

+ func (p *AgentPersonaManager) SetActiveSkills(skills []string)

+ func (p *AgentPersonaManager) SetFalseStopDetectionEnabled(v bool)

+ func (p *AgentPersonaManager) SetTaskActions(actions []TaskAction)

+ func (p *AgentPersonaManager) SetToolCallGuidanceAdded(v bool)

type AgentSecurityManager

+ func (m *AgentSecurityManager) IsFolderSessionWriteAllowed(absPath string) bool

+ func (m *AgentSecurityManager) RemoveSessionAllowedFolder(folder string) error

+ func (m *AgentSecurityManager) SetSessionAllowedFolderMode(folder, mode string)

+ func (m *AgentSecurityManager) SnapshotSessionAllowedFolderModes() map[string]string

+ type AgentSecurityStateManager struct

+ func NewAgentSecurityStateManager() *AgentSecurityStateManager

+ func (s *AgentSecurityStateManager) GetCircuitBreaker() *CircuitBreakerState

+ func (s *AgentSecurityStateManager) GetLastProviderError() *ProviderErrorInfo

+ func (s *AgentSecurityStateManager) GetLastRunTerminationReason() string

+ func (s *AgentSecurityStateManager) GetPendingStrictSwitchNotice() string

+ func (s *AgentSecurityStateManager) GetPendingSwitchContextRefresh() string

+ func (s *AgentSecurityStateManager) GetPendingSystemSupplement() string

+ func (s *AgentSecurityStateManager) GetTraceSession() interface{}

+ func (s *AgentSecurityStateManager) SetCircuitBreaker(cb *CircuitBreakerState)

+ func (s *AgentSecurityStateManager) SetLastProviderError(err *ProviderErrorInfo)

+ func (s *AgentSecurityStateManager) SetLastRunTerminationReason(reason string)

+ func (s *AgentSecurityStateManager) SetPendingStrictSwitchNotice(v string)

+ func (s *AgentSecurityStateManager) SetPendingSwitchContextRefresh(v string)

+ func (s *AgentSecurityStateManager) SetPendingSystemSupplement(v string)

+ func (s *AgentSecurityStateManager) SetTraceSession(ts interface{})

+ type AgentSessionManager struct

+ func NewAgentSessionManager(debug bool) *AgentSessionManager

+ func (m *AgentSessionManager) AddMessage(msg api.Message)

+ func (m *AgentSessionManager) AddTurnCheckpoint(cp TurnCheckpoint)

+ func (m *AgentSessionManager) GetCheckpointMutex() *sync.RWMutex

+ func (m *AgentSessionManager) GetCommandHistory() []string

+ func (m *AgentSessionManager) GetConfigOverrides() map[string]interface{}

+ func (m *AgentSessionManager) GetConversationPruner() *ConversationPruner

+ func (m *AgentSessionManager) GetCurrentContextTokens() int

+ func (m *AgentSessionManager) GetCurrentIteration() int

+ func (m *AgentSessionManager) GetHistoryIndex() int

+ func (m *AgentSessionManager) GetHistoryMutex() *sync.Mutex

+ func (m *AgentSessionManager) GetMaxContextTokens() int

+ func (m *AgentSessionManager) GetMessageTimestamps() []time.Time

+ func (m *AgentSessionManager) GetMessages() []api.Message

+ func (m *AgentSessionManager) GetOptimizer() *ConversationOptimizer

+ func (m *AgentSessionManager) GetPauseMutex() *sync.Mutex

+ func (m *AgentSessionManager) GetPauseState() *PauseState

+ func (m *AgentSessionManager) GetPreviousSummary() string

+ func (m *AgentSessionManager) GetSessionID() string

+ func (m *AgentSessionManager) GetSessionIntentEmbedding() []float32

+ func (m *AgentSessionManager) GetSessionModel() string

+ func (m *AgentSessionManager) GetSessionProvider() api.ClientType

+ func (m *AgentSessionManager) GetTurnCheckpoints() []TurnCheckpoint

+ func (m *AgentSessionManager) IsContextWarningIssued() bool

+ func (m *AgentSessionManager) SetCommandHistory(h []string)

+ func (m *AgentSessionManager) SetConfigOverrides(overrides map[string]interface{})

+ func (m *AgentSessionManager) SetContextWarningIssued(v bool)

+ func (m *AgentSessionManager) SetConversationPruner(pruner *ConversationPruner)

+ func (m *AgentSessionManager) SetCurrentContextTokens(n int)

+ func (m *AgentSessionManager) SetCurrentIteration(iter int)

+ func (m *AgentSessionManager) SetHistoryIndex(i int)

+ func (m *AgentSessionManager) SetMaxContextTokens(n int)

+ func (m *AgentSessionManager) SetMessageTimestamps(ts []time.Time)

+ func (m *AgentSessionManager) SetMessages(msgs []api.Message)

+ func (m *AgentSessionManager) SetOptimizer(o *ConversationOptimizer)

+ func (m *AgentSessionManager) SetPauseState(ps *PauseState)

+ func (m *AgentSessionManager) SetPreviousSummary(summary string)

+ func (m *AgentSessionManager) SetSessionID(id string)

+ func (m *AgentSessionManager) SetSessionIntentEmbedding(emb []float32)

+ func (m *AgentSessionManager) SetSessionIntentEmbeddingIfNil(emb []float32) bool

+ func (m *AgentSessionManager) SetSessionModel(model string)

+ func (m *AgentSessionManager) SetSessionProvider(ct api.ClientType)

+ func (m *AgentSessionManager) SetTurnCheckpoints(cps []TurnCheckpoint)

type BrokerDecision

+ Analysis *SecurityAnalysis

+ type Chain struct

+ Operators []string

+ Original string

+ Subcommands []string

+ func ParseChain(s string) Chain

+ type FileAccessDecision int

+ const FileAccessAllow

+ const FileAccessDeny

+ const FileAccessPrompt

type MockLLMProvider — darwin/amd64, linux/amd64, windows/amd64

+ func NewMockLLMProviderWithLimit(limit int) *MockLLMProvider

type RiskAssessment

+ FileMode string

+ PathTier PathTier

type RiskSource

+ const RiskSourceGitRebase

+ type SecurityAnalysis struct

+ ChainClassifications []string

+ ChainLength int

+ ChainSubcommands []string

+ Modifies string

+ Recommendation string

+ RiskAssessment string

+ Summary string

+ func AnalyzeChain(ctx context.Context, agent *Agent, chain Chain, ...) (*SecurityAnalysis, error)

+ func AnalyzeChainFallback(ctx context.Context, agent *Agent, chain Chain, ...) (*SecurityAnalysis, error)

+ func AnalyzeShellCommand(ctx context.Context, agent *Agent, command, cwd string) (*SecurityAnalysis, error)

+ type SecurityAnalysisCache struct

+ func NewSecurityAnalysisCache() *SecurityAnalysisCache

+ func (c *SecurityAnalysisCache) Clear()

+ func (c *SecurityAnalysisCache) Get(normalizedKey string) (*SecurityAnalysis, bool)

+ func (c *SecurityAnalysisCache) Set(normalizedKey string, sa *SecurityAnalysis)

type SecurityManager

+ IsFolderSessionWriteAllowed func(absPath string) bool

+ RemoveSessionAllowedFolder func(folder string) error

+ SetSessionAllowedFolderMode func(folder, mode string)

+ SnapshotSessionAllowedFolderModes func() map[string]string

+ type SessionManager interface

v0.17.6

Jul 18, 2026

v0.17.5

Jul 17, 2026

Changes in this version

+ func EvaluateCommandPolicy(command string, policies *configuration.CommandPolicies) (configuration.CommandPolicyAction, string, bool)

type Agent

+ func (a *Agent) GetImageTokens() int

+ func (a *Agent) PersistShellCommandAskPolicy(command string) error

+ func (a *Agent) ResolveBillingType() string

+ func (a *Agent) SetSlashCommands(registry any)

+ func (a *Agent) SetTrainingConfig(cfg configuration.TrainingConfig)

+ func (a *Agent) SetTrainingPushFunc(fn func(state ConversationState, endpoint string, excludePaths []string) error)

+ func (a *Agent) SlashCommands() any

type AgentState

+ ImageTokens int

type AgentStateManager

+ func (s *AgentStateManager) GetImageTokens() int

+ func (s *AgentStateManager) SetImageTokens(n int)

type CacheStats

+ GetImageTokens func() int

+ SetImageTokens func(int)

type ConversationState

+ ImageTokens int

type CostEntry

+ ImageTokens int

v0.17.4

Jul 15, 2026

v0.17.3

Jul 15, 2026

v0.17.2

Jul 15, 2026

v0.17.1

Jul 15, 2026

v0.17.0

Jul 12, 2026

v0.16.25

Jul 15, 2026

Changes in this version

+ func ContextWithSproutDir(ctx context.Context, dir string) context.Context

+ func SproutDirFromContext(ctx context.Context) string

+ func WorkflowRequiresApprovalIn(dir, workflowName string) bool

type Agent

+ func NewAgentWithLayersInWorkspace(globalDir, workspaceDir, workspaceRoot, model string) (*Agent, error)

+ func (a *Agent) Breakpoints() []Breakpoint

+ func (a *Agent) ForkAtBreakpoint(breakpointIndex int) (string, error)

+ func (a *Agent) GetTurnCheckpoints() []TurnCheckpoint

+ func (a *Agent) RotateSession() (string, error)

type AgentState

+ MessageTimestamps []time.Time

type AgentStateManager

+ func (s *AgentStateManager) GetMessageTimestamps() []time.Time

+ func (s *AgentStateManager) SetMessageTimestamps(ts []time.Time)

+ type Breakpoint struct

+ Content string

+ Index int

+ type CacheStats interface

+ GetCacheWriteTokens func() int

+ GetCachedCostSavings func() float64

+ GetCachedTokens func() int

+ SetCacheWriteTokens func(int)

+ SetCachedCostSavings func(float64)

+ SetCachedTokens func(int)

+ type CheckpointStore interface

+ AddTurnCheckpoint func(TurnCheckpoint)

+ GetCheckpointMutex func() *sync.RWMutex

+ GetTurnCheckpoints func() []TurnCheckpoint

+ SetTurnCheckpoints func([]TurnCheckpoint)

+ type CircuitBreakerStore interface

+ GetCircuitBreaker func() *CircuitBreakerState

+ SetCircuitBreaker func(*CircuitBreakerState)

+ type CommandHistoryStore interface

+ GetCommandHistory func() []string

+ GetHistoryIndex func() int

+ GetHistoryMutex func() *sync.Mutex

+ SetCommandHistory func([]string)

+ SetHistoryIndex func(int)

+ type ConfigOverrideStore interface

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

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

+ type ContextBudgetStore interface

+ GetCurrentContextTokens func() int

+ GetMaxContextTokens func() int

+ IsContextWarningIssued func() bool

+ SetContextWarningIssued func(bool)

+ SetCurrentContextTokens func(int)

+ SetMaxContextTokens func(int)

+ type ConversationPrunerStore interface

+ GetConversationPruner func() *ConversationPruner

+ SetConversationPruner func(*ConversationPruner)

+ type CostTracker interface

+ AddCost func(float64)

+ AddCostEntry func(CostEntry)

+ GetChargedCostTotal func() float64

+ GetFreeTokens func() int

+ GetSubscriptionTokens func() int

+ GetTokenCostTotal func() float64

+ GetTotalCost func() float64

+ SetChargedCostTotal func(float64)

+ SetFreeTokens func(int)

+ SetSubscriptionTokens func(int)

+ SetTokenCostTotal func(float64)

+ SetTotalCost func(float64)

+ type EstimatedTokenStore interface

+ GetEstimatedTokenResponses func() int

+ SetEstimatedTokenResponses func(int)

+ type FalseStopStore interface

+ IsFalseStopDetectionEnabled func() bool

+ SetFalseStopDetectionEnabled func(bool)

+ type IterationStore interface

+ GetCurrentIteration func() int

+ SetCurrentIteration func(int)

+ type LLMCallTracker interface

+ GetLLMCallCount func() int

+ IncrementLLMCallCount func()

+ SetLLMCallCount func(int)

+ type MessageStore interface

+ AddMessage func(api.Message)

+ GetMessageTimestamps func() []time.Time

+ GetMessages func() []api.Message

+ SetMessageTimestamps func([]time.Time)

+ SetMessages func([]api.Message)

+ type OptimizerStore interface

+ GetOptimizer func() *ConversationOptimizer

+ SetOptimizer func(*ConversationOptimizer)

type OutputRouter

+ func (r *OutputRouter) TerminalSubscriberActive() bool

+ type PauseStore interface

+ GetPauseMutex func() *sync.Mutex

+ GetPauseState func() *PauseState

+ SetPauseState func(*PauseState)

+ type PendingStateStore interface

+ GetPendingStrictSwitchNotice func() string

+ GetPendingSwitchContextRefresh func() string

+ GetPendingSystemSupplement func() string

+ SetPendingStrictSwitchNotice func(string)

+ SetPendingSwitchContextRefresh func(string)

+ SetPendingSystemSupplement func(string)

+ type PersonaStore interface

+ GetActivePersona func() string

+ GetActiveSkills func() []string

+ SetActivePersona func(string)

+ SetActiveSkills func([]string)

+ type ProviderErrorStore interface

+ GetLastProviderError func() *ProviderErrorInfo

+ SetLastProviderError func(*ProviderErrorInfo)

+ type SessionConfigStore interface

+ GetSessionModel func() string

+ GetSessionProvider func() api.ClientType

+ SetSessionModel func(string)

+ SetSessionProvider func(api.ClientType)

+ type SessionIntentStore interface

+ GetSessionIntentEmbedding func() []float32

+ SetSessionIntentEmbedding func([]float32)

+ SetSessionIntentEmbeddingIfNil func(emb []float32) bool

+ type SessionStore interface

+ GetSessionID func() string

+ SetSessionID func(string)

+ type SummaryStore interface

+ GetPreviousSummary func() string

+ SetPreviousSummary func(string)

+ type TaskActionStore interface

+ AddTaskAction func(TaskAction)

+ GetTaskActions func() []TaskAction

+ GetTaskActionsMutex func() *sync.RWMutex

+ SetTaskActions func([]TaskAction)

+ type TerminationStore interface

+ GetLastRunTerminationReason func() string

+ SetLastRunTerminationReason func(string)

+ type TokenCounter interface

+ GetCompletionTokens func() int

+ GetPromptTokens func() int

+ GetTotalTokens func() int

+ SetCompletionTokens func(int)

+ SetPromptTokens func(int)

+ SetTotalTokens func(int)

+ type ToolCallTracker interface

+ GetTotalToolCalls func() int

+ IncrementTotalToolCalls func()

+ SetTotalToolCalls func(int)

+ type ToolGuidanceStore interface

+ IsToolCallGuidanceAdded func() bool

+ SetToolCallGuidanceAdded func(bool)

+ type TraceStore interface

+ GetTraceSession func() interface{}

+ SetTraceSession func(interface{})

v0.16.24

Jul 6, 2026

v0.16.23

Jul 6, 2026

v0.16.22

Jul 6, 2026

v0.16.21

Jul 6, 2026

v0.16.20

Jul 6, 2026

Changes in this version

type MockLLMProvider — darwin/amd64, linux/amd64, windows/amd64

+ func (m *MockLLMProvider) VisionCapabilities() api.VisionCapabilities

v0.16.19

Jul 5, 2026

Changes in this version

+ const BillingFree

+ const BillingPayPerToken

+ const BillingSubscription

+ const DefaultMaxRetries

+ const DefaultMinMemoryBytes

+ const DefaultRetryMinBytes

+ const DefaultRetrySleep

+ func ExecuteTool(ctx context.Context, toolName string, args map[string]interface{}, ...) ([]api.ImageData, string, error)

+ func FormatWakeupBatch(notifications []Notification) string

+ func GetSettingValue(cfg *configuration.Config, key string) (string, error)

+ func InstrumentedRecall(a *Agent, ctx context.Context, query string)

+ func IsMemoryIntensiveCommand(cmd string) bool

+ func SetActiveComputerUseAgent(a *Agent)

+ func SetSettingValue(cfg *configuration.Config, key, value string) error

+ func SettingEnumValues(key string) []string

+ func SettingIsListType(key string) bool

+ func SupportedSettingKeys() []string

type Agent

+ func (a *Agent) AllowAppForComputerUse(key string)

+ func (a *Agent) DisableWakeup()

+ func (a *Agent) DrainNotifications() []Notification

+ func (a *Agent) EnableWakeupIfDisabled()

+ func (a *Agent) GetChargedCostTotal() float64

+ func (a *Agent) GetTokenCostTotal() float64

+ func (a *Agent) HasPendingNotifications() bool

+ func (a *Agent) IncrementWakeupResume(cfg configuration.WakeupConfig) bool

+ func (a *Agent) IsAppAllowedForComputerUse(key string) bool

+ func (a *Agent) IsWakeupDisabled() bool

+ func (a *Agent) NotifyCompletion(sessionID, kind, content string)

+ func (a *Agent) PublishRateLimited(ev *events.RateLimitedEvent)

+ func (a *Agent) QueueNotification(n Notification)

+ func (a *Agent) Recall(ctx context.Context, query string, limit int) ([]RecalledItem, error)

+ func (a *Agent) RecordErrorCategory(err error)

+ func (a *Agent) RecordWakeupTokens(tokens int, cfg configuration.WakeupConfig)

+ func (a *Agent) RefreshRuntimeConfig(ctx context.Context) error

+ func (a *Agent) RefreshSkills() error

+ func (a *Agent) RequestShellApproval(ctx context.Context, p ShellProposal) (map[string]bool, error)

+ func (a *Agent) SteeringChannel() <-chan string

type AgentState

+ ChargedCostTotal float64

+ FreeTokens int

+ SubscriptionTokens int

+ TokenCostTotal float64

type AgentStateManager

+ func (s *AgentStateManager) AddCostEntry(entry CostEntry)

+ func (s *AgentStateManager) GetChargedCostTotal() float64

+ func (s *AgentStateManager) GetFreeTokens() int

+ func (s *AgentStateManager) GetSubscriptionTokens() int

+ func (s *AgentStateManager) GetTokenCostTotal() float64

+ func (s *AgentStateManager) SetChargedCostTotal(v float64)

+ func (s *AgentStateManager) SetFreeTokens(v int)

+ func (s *AgentStateManager) SetSubscriptionTokens(v int)

+ func (s *AgentStateManager) SetTokenCostTotal(v float64)

+ type CommandKind string

+ const CommandKindChmod

+ const CommandKindChown

+ const CommandKindDocker

+ const CommandKindGitPush

+ const CommandKindGitReset

+ const CommandKindHttpPost

+ const CommandKindKubectl

+ const CommandKindRm

+ const CommandKindUnknown

+ const CommandKindWriteRedirect

+ func ClassifyShellSegment(segment string) CommandKind

+ func ClassifyShellSegmentWithSemantic(segment string) (CommandKind, string)

+ type CostEntry struct

+ BillingType string

+ CachedTokens int

+ ChargedCost float64

+ CompletionTokens int

+ Model string

+ PromptTokens int

+ Provider string

+ TokenCost float64

+ type MemoryGate struct

+ MaxRetries int

+ MinMemoryBytes int64

+ RetryMinBytes int64

+ RetrySleep time.Duration

+ func DefaultMemoryGate() *MemoryGate

+ func (g *MemoryGate) Check() error

+ type MemoryGateError struct

+ AvailableBytes int64

+ RequiredBytes int64

+ Retried bool

+ func (e *MemoryGateError) Error() string

type MockLLMProvider — darwin/amd64, linux/amd64, windows/amd64

+ func (m *MockLLMProvider) SupportsConversationalVision() bool

+ type Notification struct

+ Content string

+ Kind NotificationKind

+ SessionID string

+ Timestamp time.Time

+ func (n Notification) FormatForAgent() string

+ type NotificationKind string

+ const NotifAutomate

+ const NotifShellBg

+ const NotifShellBgTimeout

+ type OOMProbeResult struct — darwin/amd64, linux/amd64, windows/amd64

+ NodeCount int

+ Timestamp time.Time

+ TotalRSSBytes uint64

+ type OOMProbeResult struct — js/wasm

+ type OOMWatchdog struct

+ func NewOOMWatchdog() *OOMWatchdog

+ func NewOOMWatchdog(eventBus *events.EventBus) *OOMWatchdog

+ func (w *OOMWatchdog) Start()

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

+ func (w *OOMWatchdog) Stop()

type OutputRouter

+ func (r *OutputRouter) SetTerminalSubscriberActive(active bool)

+ func (r *OutputRouter) Write(p []byte) (int, error)

+ type RecallMetricsRecord struct

+ CheckpointIDs []string

+ ItemsRecalled int

+ RecallLatencyMS int64

+ RecallQuery string

+ SessionID string

+ Timestamp string

+ TopSimilarity float64

+ UsedInResponse bool

+ Workspaces []string

type ScriptedClient

+ func (c *ScriptedClient) SupportsConversationalVision() bool

+ type SettingDetail struct

+ Description string

+ GetValue func(cfg *configuration.Config) string

+ Key string

+ ListType bool

+ ValidValues string

+ func AllSettings() []SettingDetail

+ type ShellPart struct

+ ID string

+ Kind CommandKind

+ Semantic string

+ Text string

+ func SplitShellIntoParts(cmd string) []ShellPart

+ type ShellProposal struct

+ Command string

+ Parts []ShellPart

+ RiskLevel configuration.RiskLevel

+ func NewShellProposal(cmd string) ShellProposal

+ func (p ShellProposal) HighRiskParts() []ShellPart

+ func (p ShellProposal) MostDestructivePart() *ShellPart

type StateManager

+ AddCostEntry func(CostEntry)

+ GetChargedCostTotal func() float64

+ GetFreeTokens func() int

+ GetSubscriptionTokens func() int

+ GetTokenCostTotal func() float64

+ SetChargedCostTotal func(float64)

+ SetFreeTokens func(int)

+ SetSubscriptionTokens func(int)

+ SetTokenCostTotal func(float64)

type SubagentResult

+ OutputComplete bool

+ type WorkflowBudgetConfig struct

+ USD float64

+ WarnAt []float64

+ type WorkflowLoopConfig struct

+ BuildCommand string

+ GatePromptFile string

+ MaxIterations int

+ MaxRetries int

+ TodoFile string

+ type WorkflowProgressConfig struct

+ HeartbeatSeconds int

+ type WorkflowResult struct

+ Error error

+ ItemsFailed int

+ ItemsProcessed int

+ ItemsSkipped int

+ func RunWorkflowLoopInProcess(ctx context.Context, parentAgent *Agent, configPath string, ...) (*WorkflowResult, error)

v0.16.18

Jun 29, 2026

Changes in this version

+ var UseMockLLM bool — darwin/amd64, linux/amd64, windows/amd64

+ func CleanupPasswordRequestForTest(requestID string)

+ func ListChangesEmpty() string

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

+ func RegisterComputerUseTools(cfg *configuration.Config) error

+ func RegisterPasswordRequestForTest(requestID string) chan string

+ func SummarizeMySessionEmpty() string

type Agent

+ func (a *Agent) GetPasswordPrompter() tools.PasswordPrompter

+ func (a *Agent) GetSessionName() string

+ func (a *Agent) GetVisionProcessor() *tools.VisionProcessor

+ func (a *Agent) HasPasswordPrompter() bool

+ func (a *Agent) RequestApproval(assessment RiskAssessment, toolName string, args map[string]interface{}) (BrokerDecision, error)

+ func (a *Agent) ResetComputerUseSessionApproval()

+ func (a *Agent) RespondToPasswordRequest(requestID string, password string) bool

+ func (a *Agent) SetPasswordPrompter(pp tools.PasswordPrompter)

+ type BrokerDecision struct

+ Approved bool

+ Assessment RiskAssessment

+ Decision security.ApprovalDecision

+ Outcome security.ApprovalOutcome

+ Surface string

+ type CLIPasswordPrompter struct

+ func NewCLIPasswordPrompter() *CLIPasswordPrompter

+ func (cli *CLIPasswordPrompter) Prompt(ctx context.Context, reason string) (string, error)

+ type MockLLMProvider struct — darwin/amd64, linux/amd64, windows/amd64

+ CallCount int

+ DefaultResponse string

+ ResponsesByPrompt map[string]string

+ func NewMockLLMProvider() *MockLLMProvider

+ func (m *MockLLMProvider) CheckConnection() error

+ func (m *MockLLMProvider) GetAverageTPS() float64

+ func (m *MockLLMProvider) GetLastTPS() float64

+ func (m *MockLLMProvider) GetModel() string

+ func (m *MockLLMProvider) GetModelContextLimit() (int, error)

+ func (m *MockLLMProvider) GetProvider() string

+ func (m *MockLLMProvider) GetTPSStats() map[string]float64

+ func (m *MockLLMProvider) GetVisionModel() string

+ func (m *MockLLMProvider) ListModels(ctx context.Context) ([]api.ModelInfo, error)

+ func (m *MockLLMProvider) ResetTPSStats()

+ func (m *MockLLMProvider) SendChatRequest(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (m *MockLLMProvider) SendChatRequestStream(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (m *MockLLMProvider) SendVisionRequest(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (m *MockLLMProvider) SetDebug(debug bool)

+ func (m *MockLLMProvider) SetModel(model string) error

+ func (m *MockLLMProvider) SupportsVision() bool

type RiskSource

+ const RiskSourcePasswordPrompter

+ type WebUIPasswordPrompter struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewWebUIPasswordPrompter(agent *Agent) *WebUIPasswordPrompter

+ func (wp *WebUIPasswordPrompter) Prompt(ctx context.Context, reason string) (string, error)

v0.16.17

Jun 24, 2026

Changes in this version

+ var ErrQueryInProgress = errors.New("a query is already in progress on this agent")

+ func SetEditApprovalTimeout(d time.Duration)

type Agent

+ func (a *Agent) EndQuery()

+ func (a *Agent) GetCacheWriteTokens() int

+ func (a *Agent) IsQueryInProgress() bool

+ func (a *Agent) RespondToEditApproval(requestID string, decision EditDecision) bool

+ func (a *Agent) TryBeginQuery() error

type AgentState

+ CacheWriteTokens int

type AgentStateManager

+ func (s *AgentStateManager) GetCacheWriteTokens() int

+ func (s *AgentStateManager) SetCacheWriteTokens(n int)

type ConversationState

+ CacheWriteTokens int

type StateManager

+ GetCacheWriteTokens func() int

+ SetCacheWriteTokens func(int)

v0.16.16

Jun 22, 2026

v0.16.15

Jun 22, 2026

v0.16.14

Jun 22, 2026

v0.16.13

Jun 22, 2026

v0.16.12

Jun 22, 2026

Changes in this version

+ func ApplyHunks(original string, hunks []Hunk, acceptedIDs []string) string

+ func FormatAnalysisForPrompt(analysis SecurityLLMAnalysis, ok bool) string

+ func GenerateUnifiedDiff(path, original, proposed string) (string, error)

type Agent

+ func (a *Agent) GetAuditLogger() *tools.AuditLogger

+ func (a *Agent) GetSecurityCautionsIssued() int64

+ func (a *Agent) GetSecurityLLMClassifier() *SecurityLLMClassifier

+ func (a *Agent) GetSecurityLoopsDetected() int64

+ func (a *Agent) GetSecurityRetriesAfterCaution() int64

+ func (a *Agent) GetUnsafeShellMode() bool

+ func (a *Agent) IsPathOutsideWorkspace(path string) bool

+ func (a *Agent) MergeSubagentChanges(changes []TrackedFileChange, persona string)

+ func (a *Agent) PersistShellCommandPattern(pattern string) error

+ func (a *Agent) RequestEditApproval(ctx context.Context, p EditProposal) (applied string, summary string, err error)

+ func (a *Agent) Rewind(opts RewindOptions) (*RewindResult, error)

+ func (a *Agent) SetAuditLogger(l *tools.AuditLogger)

+ func (a *Agent) SetUnsafeShellMode(unsafe bool)

+ func (a *Agent) ShouldGateEdit(path string) bool

type AgentSecurityManager

+ func (m *AgentSecurityManager) GetUnsafeShellMode() bool

+ func (m *AgentSecurityManager) SetUnsafeShellMode(unsafe bool)

type ChangeTracker

+ func (ct *ChangeTracker) MergeChild(changes []TrackedFileChange, source string)

type ClarificationRequest

+ SubagentID string

+ type DiffLine struct

+ Content string

+ Type DiffLineType

+ type DiffLineType string

+ const DiffLineAdd

+ const DiffLineContext

+ const DiffLineRemove

+ type EditDecision struct

+ AcceptedHunks []string

+ Approved bool

+ type EditProposal struct

+ Hunks []Hunk

+ Original string

+ Path string

+ Proposed string

+ type Hunk struct

+ ID string

+ Lines []DiffLine

+ NewLines int

+ NewStart int

+ OldLines int

+ OldStart int

+ func SplitIntoHunks(original, proposed string) []Hunk

+ type RewindOptions struct

+ RevertFiles bool

+ ToTurnIndex int

+ type RewindResult struct

+ CheckpointsDropped int

+ FilesReverted []string

+ FilesSkipped []string

+ MessagesRemoved int

+ TurnsDiscarded int

type RiskSource

+ const RiskSourceFSTier

+ const RiskSourceGitHistoryRewrite

+ const RiskSourceGitWrite

+ const RiskSourceHandler

+ const RiskSourceWorkspacePolicy

+ type SecurityLLMAnalysis struct

+ Recommendation string

+ Risk string

+ Summary string

+ type SecurityLLMClassifier struct

+ func NewSecurityLLMClassifier(cfg *configuration.Config, logger *utils.Logger) (*SecurityLLMClassifier, error)

+ func (c *SecurityLLMClassifier) Analyze(ctx context.Context, toolName string, command string, heuristicRisk string) (SecurityLLMAnalysis, bool)

type SecurityManager

+ GetUnsafeShellMode func() bool

+ SetUnsafeShellMode func(unsafe bool)

type TrackedFileChange

+ Source string

v0.16.11

Jun 11, 2026

v0.16.10

Jun 11, 2026

v0.16.9

Jun 11, 2026

v0.16.8

Jun 11, 2026

Changes in this version

+ func ParseJSONOrderedAny(content string) (interface{}, error)

v0.16.7

Jun 9, 2026

Changes in this version

type Agent

+ func (a *Agent) ResolveToolRisk(toolName string, args map[string]interface{}) RiskAssessment

+ type RiskAssessment struct

+ IsHardBlock bool

+ Level configuration.RiskLevel

+ Reason string

+ RequiresIntentConfirmation bool

+ Sources []RiskSource

+ func (ra RiskAssessment) Explain() string

+ type RiskSource string

+ const RiskSourceClassifier

+ const RiskSourceCriticalOp

+ const RiskSourcePersonaCascade

v0.16.6

Jun 8, 2026

Changes in this version

+ func AssertNoStateLeak(realDir string, before map[string]time.Time) int

+ func NewTestStateDir(t *testing.T) func()

+ func SetTestStateDirHook(dir string) func()

+ func SnapshotRealStateDir() (realDir string, before map[string]time.Time)

v0.16.5

Jun 6, 2026

v0.16.4

Jun 6, 2026

Changes in this version

+ const CompactedFilesHeader

+ const TranscriptSnapshotFormat

+ func BuildToolDefinitions() []api.Tool

+ func FormatFileChangesForSummary(changes []TranscriptFileChange) string

+ func FormatSemanticRecall(items []RecalledItem) string

+ func GetEmbeddedRollupPrompt() string

+ func ListTranscriptSnapshots(sessionID, workingDir string) ([]string, error)

+ func NormalizeYAMLOrdered(v interface{}) interface

+ func SerializeJSONOrdered(data interface{}) (string, error)

+ func SerializeYAMLOrdered(data interface{}) (string, error)

+ func WorkflowRequiresApproval(workflowName string) bool

type Agent

+ func (a *Agent) BuildTranscriptSnapshot(label string, includePreview bool) *TranscriptSnapshot

+ func (a *Agent) CaptureTranscriptSnapshot(label string, includePreview bool) (string, error)

+ func (a *Agent) GetFleetUsdBudget() *FleetUsdBudget

+ func (a *Agent) InjectSemanticRecall(ctx context.Context, query string)

+ func (a *Agent) IsWorkflowApprovedInSession(workflow string) bool

+ func (a *Agent) MarkWorkflowApprovedInSession(workflow string)

+ func (a *Agent) PublishBudgetUpdate(eventType string, data interface{})

+ func (a *Agent) PublishCompactCompleted(source string, beforeCount, afterCount, summaryChars int, err error)

+ func (a *Agent) PublishCompactStarted(source string, messageCount, checkpointCount int)

+ func (a *Agent) PublishContextManagementDiagnostic(currentTokens, maxTokens, iteration, messageCount int)

+ func (a *Agent) PublishRecallDiagnostic(diag recallRetrievalDiagnostic)

+ func (a *Agent) RunAutomateWorkflow(ctx context.Context, workflow string) (string, error)

+ func (a *Agent) SetBudgetExceededCallback(fn func(spent, limit float64))

+ func (a *Agent) SetBudgetWarningCallback(fn func(threshold, spent, limit float64))

+ func (a *Agent) SetFleetUsdBudget(b *FleetUsdBudget)

+ func (a *Agent) SummarizeViaLLM(ctx context.Context, messages []api.Message, hint core.SummarizerHint) (string, error)

+ type CompactPreview struct

+ AfterMessageCount int

+ BeforeMessageCount int

+ CompactedMessages []api.Message

+ RemainingCheckpoints []TurnCheckpoint

+ WouldReduce bool

+ type FleetUsdBudget struct

+ func NewFleetUsdBudget(limit float64, warnAt []float64) *FleetUsdBudget

+ func (b *FleetUsdBudget) Add(cost float64) (newSpent float64, crossed []float64, justExceeded bool)

+ func (b *FleetUsdBudget) Exceeded() bool

+ func (b *FleetUsdBudget) Snapshot() (spent, limit float64)

+ type MessageAnnotation struct

+ ContentChars int

+ FirstLine string

+ Index int

+ Role string

+ Source MessageSource

+ ToolCallCount int

+ type MessageSource string

+ const MessageSourceLLMCheckpoint

+ const MessageSourceOriginal

+ type OrderedMap struct

+ func NewOrderedMap() *OrderedMap

+ func OrderedMapFromMap(m map[string]interface{}) *OrderedMap

+ func ParseJSONOrdered(content string) (*OrderedMap, error)

+ func ParseYAMLOrdered(content string) (*OrderedMap, error)

+ func (om *OrderedMap) Delete(key string)

+ func (om *OrderedMap) Get(key string) (interface{}, bool)

+ func (om *OrderedMap) InOrder() []orderedmap.Pair[string, interface{}]

+ func (om *OrderedMap) Keys() []string

+ func (om *OrderedMap) Len() int

+ func (om *OrderedMap) Set(key string, value interface{})

+ func (om *OrderedMap) String() string

+ func (om *OrderedMap) ToMap() map[string]interface{}

+ type RecalledItem struct

+ Actionable string

+ AgeDays float64

+ CheckpointID string

+ EndIndex int

+ Level int

+ Score float64

+ Similarity float32

+ StartIndex int

+ Summary string

+ Workspace string

+ type TranscriptDiff struct

+ ChangedIndices []TranscriptDiffEntry

+ MessagesDroppedAtTail int

+ MessagesReplacedByRole map[string]int

+ NewFileChanges []TranscriptFileChange

+ NewerCheckpointCount int

+ NewerFileChangeCount int

+ NewerMessageCount int

+ NewerPath string

+ NewerTimestamp time.Time

+ NewerTotalTokens int

+ Notes []string

+ OlderCheckpointCount int

+ OlderFileChangeCount int

+ OlderMessageCount int

+ OlderPath string

+ OlderTimestamp time.Time

+ OlderTotalTokens int

+ func DiffTranscriptSnapshots(older, newer *TranscriptSnapshot) *TranscriptDiff

+ type TranscriptDiffEntry struct

+ Index int

+ NewerFirstLine string

+ NewerRole string

+ NewerSource string

+ OlderFirstLine string

+ OlderRole string

+ OlderSource string

+ type TranscriptFileChange struct

+ BulkCount int

+ Operation string

+ Path string

+ Source string

+ Timestamp time.Time

+ ToolCall string

+ func ExtractFileChangesFromMessages(messages []api.Message) []TranscriptFileChange

+ type TranscriptSnapshot struct

+ ChangeTrackerRev string

+ CompactPreview *CompactPreview

+ FileChanges []TranscriptFileChange

+ Format string

+ Label string

+ MessageAnnotations []MessageAnnotation

+ SessionID string

+ State *ConversationState

+ Timestamp time.Time

+ WorkingDirectory string

+ func LoadTranscriptSnapshot(path string) (*TranscriptSnapshot, error)

type TurnCheckpoint

+ CoveredTurns int

+ ID string

+ Level int

+ SourceCheckpointIDs []string

v0.16.3

Jun 3, 2026

v0.16.2

Jun 3, 2026

Changes in this version

type OutputRouter

+ func (r *OutputRouter) SetReasoningCallback(fn func(string))

+ type TrackedBulkItem struct

+ FilePath string

+ NewCode string

+ Operation string

+ OriginalCode string

type TrackedFileChange

+ BulkCount int

+ BulkItems []TrackedBulkItem

v0.16.1

Jun 1, 2026

v0.16.0

Jun 1, 2026

Changes in this version

+ const BATCH_SIZE

+ const DefaultClarificationTimeout

+ const DefaultDriftCheckInterval

+ const DefaultDriftThreshold

+ const DefaultSubagentTokenBudget

+ const MAX_SUBAGENT_CONTEXT_SIZE

+ const MAX_SUBAGENT_OUTPUT_SIZE

+ const MaxDriftRejections

+ const PruneStrategyAdaptive

+ const PruneStrategyHybrid

+ const PruneStrategyImportance

+ const PruneStrategyNone

+ const PruneStrategySlidingWindow

+ const RedactedContentMarker

+ const RunTerminationCompleted

+ const RunTerminationFleetBudgetExceeded

+ const RunTerminationInterrupted

+ const RunTerminationMaxIterations

+ const SkillFileName

+ var ErrCancelled = errors.New("user cancelled")

+ var ErrModelNotAvailable = errors.New("configured model is not available for this provider")

+ var ErrProviderNotConfigured = errors.New("provider is not configured — configure via webui settings")

+ var ErrUINotAvailable = errors.New("UI not available")

+ var ErrWriteHasUnsyncedEdits = errors.New("write refused: user has unsynced edits to this file")

+ var ErrWriteStale = errors.New("write refused: file may be stale")

+ var FleetBudgetExceededError = errors.New("fleet token budget exceeded")

+ var MILESTONE_PHASES = []string

+ var PruningConfig = struct{ ... }

+ func BuildScopedSessionPathForTesting(stateDir, sessionID, workingDir string) (string, error)

+ func DecrementActiveSubagents()

+ func DeleteMemory(name string) error

+ func DeleteMemoryEmbedding(mgr *embedding.EmbeddingManager, name string) error

+ func DeleteSession(sessionID string) error

+ func DeleteSessionScoped(sessionID, workingDir string) error

+ func DetectLanguages(dir string) []string

+ func EmbedAndStoreTurn(ctx context.Context, mgr *embedding.EmbeddingManager, turn *ConversationTurn) error

+ func EmbedMemory(ctx context.Context, mgr *embedding.EmbeddingManager, name string, ...) error

+ func EstimateTokens(text string) int

+ func ExportStateToJSON(state *ConversationState) ([]byte, error)

+ func FormatCLIMessage(similarity float64, threshold float64) string

+ func FormatProactiveContext(results []ProactiveContextResult, config ProactiveContextConfig, now time.Time) string

+ func GetActiveSubagents() int

+ func GetEmbeddedPlanningPrompt(createTodos bool) (string, error)

+ func GetEmbeddedSystemPrompt() (string, error)

+ func GetEmbeddedSystemPromptWithProvider(provider string) (string, error)

+ func GetSessionName(sessionID string) string

+ func GetSessionNameScoped(sessionID, workingDir string) string

+ func GetSessionPreview(sessionID string) string

+ func GetSessionPreviewScoped(sessionID, workingDir string) string

+ func GetSkillManifest(content string) (map[string]string, string, error)

+ func GetStateDir() (string, error)

+ func HasUserApproval(ctx context.Context) bool

+ func IncrementActiveSubagents()

+ func InitializeToolRegistry()

+ func IsInteractiveTool(name string) bool

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

+ func LoadContextFiles() (string, error)

+ func LoadMemoriesForPrompt() string

+ func LoadMemoryContent(name string) (string, error)

+ func MigrateMemories(ctx context.Context, mgr *embedding.EmbeddingManager)

+ func NewConversationPruner(debug bool) *core.ConversationPruner

+ func NewSeedToolRegistry(agent *Agent) *core.ToolRegistry

+ func NewSproutProvider(agent *Agent, client api.ClientInterface) (core.Provider, error)

+ func NewSproutToolExecutor(agent *Agent, exec *ToolExecutor) core.ToolExecutor

+ func ParseAgentsMd(path string) (name string, description string)

+ func PublishModel(model string)

+ func RenameSession(sessionID string, newName string) error

+ func RenameSessionScoped(sessionID, newName, workingDir string) error

+ func ResetMigrationForTesting()

+ func SaveMemory(name string, content string) error

+ func SetGetStateDirForTest(dir string) func() (string, error)

+ func SetGetStateDirForTestError(msg string) func() (string, error)

+ func SetGetStateDirFunc(fn func() (string, error)) func() (string, error)

+ func SetPackageDebugLogging(enabled bool)

+ func SetPackageLogger(l *AgentLogger)

+ func SetStateDirFuncForTesting(fn func() (string, error)) func()

+ func SweepExpiredEntries(retentionDays int, storePath string) (int, error)

+ func UseSeedLoop() bool

+ func ValidateStreamConfig(sc *StreamConfig) error

+ func WithUserApproved(ctx context.Context) context.Context

+ func WriteTestSessionFile(stateDir, sessionID, workingDir string, state *ConversationState) error

+ type Agent struct

+ func NewAgent() (*Agent, error)

+ func NewAgentWithClient(client api.ClientInterface, clientType api.ClientType, ...) (*Agent, error)

+ func NewAgentWithConfigDir(configDir, model string) (*Agent, error)

+ func NewAgentWithLayers(globalDir, workspaceDir, model string) (*Agent, error)

+ func NewAgentWithModel(model string) (*Agent, error)

+ func NewTestAgent() *Agent

+ func (a *Agent) AddMessage(message api.Message)

+ func (a *Agent) AddSessionAllowedFolder(folder string)

+ func (a *Agent) AddTaskAction(actionType, description, details string)

+ func (a *Agent) AddToHistory(command string)

+ func (a *Agent) ApplyPersona(personaID string) error

+ func (a *Agent) ApplyState(state *ConversationState)

+ func (a *Agent) ApplySyncOp(op SyncOp, workspaceRoot string) SyncOpResult

+ func (a *Agent) ApplySyncOpBatch(ops []SyncOp, workspaceRoot string) []SyncOpResult

+ func (a *Agent) BuildCheckpointCompactedMessages(messages []api.Message) ([]api.Message, []TurnCheckpoint)

+ func (a *Agent) CanSpawnSubagents() bool

+ func (a *Agent) CheckFileContentSecurity(filePath string, content string)

+ func (a *Agent) CheckForInterrupt() bool

+ func (a *Agent) CheckPatchConflict(path string) (bool, string)

+ func (a *Agent) ClearActivePersona()

+ func (a *Agent) ClearConversationHistory()

+ func (a *Agent) ClearInputInjectionContext()

+ func (a *Agent) ClearInterrupt()

+ func (a *Agent) ClearSessionOverrides()

+ func (a *Agent) ClearShellCommandHistory()

+ func (a *Agent) ClearTrackedChanges()

+ func (a *Agent) CommitChanges(llmResponse string) error

+ func (a *Agent) ConsumePendingStrictSwitchNotice() string

+ func (a *Agent) DeferredMessageCount() int

+ func (a *Agent) DisableAutoPruning()

+ func (a *Agent) DisableChangeTracking()

+ func (a *Agent) DisableEmbeddingIndex()

+ func (a *Agent) DisableStreaming()

+ func (a *Agent) DrainDeferredMessages() []string

+ func (a *Agent) ElevateSessionToPermissive()

+ func (a *Agent) EnableAutoPruning()

+ func (a *Agent) EnableChangeTracking(instructions string)

+ func (a *Agent) EnableEmbeddingIndex() error

+ func (a *Agent) EnableStreaming(callback func(string))

+ func (a *Agent) EnqueueDeferredMessage(text string)

+ func (a *Agent) EvaluateOperationRisk(command string) configuration.RiskLevel

+ func (a *Agent) ExportState() ([]byte, error)

+ func (a *Agent) FleetBudgetExceeded() bool

+ func (a *Agent) GenerateActionSummary() string

+ func (a *Agent) GenerateCompactSummary() string

+ func (a *Agent) GenerateConversationSummary() string

+ func (a *Agent) GenerateResponse(messages []api.Message) (string, error)

+ func (a *Agent) GenerateSessionSummary() string

+ func (a *Agent) GetActivePersona() string

+ func (a *Agent) GetActiveRiskProfile() configuration.RiskProfile

+ func (a *Agent) GetAllShellCommandHistory() map[string]*ShellCommandResult

+ func (a *Agent) GetAvailablePersonaIDs() []string

+ func (a *Agent) GetAvailableToolNames() []string

+ func (a *Agent) GetAverageTPS() float64

+ func (a *Agent) GetBackgroundProcessManager() *tools.BackgroundProcessManager

+ func (a *Agent) GetCachedCostSavings() float64

+ func (a *Agent) GetCachedTokens() int

+ func (a *Agent) GetChangeCount() int

+ func (a *Agent) GetChangeTracker() *ChangeTracker

+ func (a *Agent) GetChangesSummary() string

+ func (a *Agent) GetCompletionTokens() int

+ func (a *Agent) GetConfig() *configuration.Config

+ func (a *Agent) GetConfigManager() *configuration.Manager

+ func (a *Agent) GetConfigOverrides() map[string]interface{}

+ func (a *Agent) GetContextTokens() (used, limit int)

+ func (a *Agent) GetContextWarningIssued() bool

+ func (a *Agent) GetCurrentContextTokens() int

+ func (a *Agent) GetCurrentIteration() int

+ func (a *Agent) GetCurrentTPS() float64

+ func (a *Agent) GetDebugLogPath() string

+ func (a *Agent) GetElevationGate() *security.ElevationGate

+ func (a *Agent) GetEmbeddingManager() *embedding.EmbeddingManager

+ func (a *Agent) GetEstimatedTokenResponses() int

+ func (a *Agent) GetEventBus() *events.EventBus

+ func (a *Agent) GetEventChatID() string

+ func (a *Agent) GetEventClientID() string

+ func (a *Agent) GetEventUserID() string

+ func (a *Agent) GetFileMetadata(path string) (WorkspaceFileMetadata, bool)

+ func (a *Agent) GetHistory() []string

+ func (a *Agent) GetHistoryCommand(index int) string

+ func (a *Agent) GetHistorySize() int

+ func (a *Agent) GetInputInjectionContext() <-chan string

+ func (a *Agent) GetLLMCallCount() int

+ func (a *Agent) GetLastMessages(n int) []api.Message

+ func (a *Agent) GetLastPreparedToolNames() []string

+ func (a *Agent) GetLastRunTerminationReason() string

+ func (a *Agent) GetLastTPS() float64

+ func (a *Agent) GetMaxContextTokens() int

+ func (a *Agent) GetMaxIterations() int

+ func (a *Agent) GetMessages() []api.Message

+ func (a *Agent) GetModel() string

+ func (a *Agent) GetOptimizationStats() map[string]interface{}

+ func (a *Agent) GetOutputRedactor() *security.OutputRedactor

+ func (a *Agent) GetPersonaProviderModel(personaID string) (string, string, error)

+ func (a *Agent) GetPreviousSummary() string

+ func (a *Agent) GetPromptTokens() int

+ func (a *Agent) GetProvider() string

+ func (a *Agent) GetProviderType() api.ClientType

+ func (a *Agent) GetPruningStats() map[string]interface{}

+ func (a *Agent) GetRevisionID() string

+ func (a *Agent) GetSecurityApprovalMgr() *security.ApprovalManager

+ func (a *Agent) GetSessionID() string

+ func (a *Agent) GetShellCommandHistoryEntry(command string) (*ShellCommandResult, bool)

+ func (a *Agent) GetShellCwd() string

+ func (a *Agent) GetSubagentRunner() *SubagentRunner

+ func (a *Agent) GetSyncStatus() map[string]WorkspaceFileMetadata

+ func (a *Agent) GetSystemPrompt() string

+ func (a *Agent) GetTPSStats() map[string]float64

+ func (a *Agent) GetTaskActions() []TaskAction

+ func (a *Agent) GetTerminalManager() tools.TerminalAccess

+ func (a *Agent) GetTodoManager() *tools.TodoManager

+ func (a *Agent) GetTotalCost() float64

+ func (a *Agent) GetTotalTokens() int

+ func (a *Agent) GetTrackedFiles() []string

+ func (a *Agent) GetUnsafeMode() bool

+ func (a *Agent) GetValidator() *validation.Validator

+ func (a *Agent) GetWorkspaceRoot() string

+ func (a *Agent) HandleInterrupt() string

+ func (a *Agent) HasActiveWebUIClients() bool

+ func (a *Agent) HasSessionOverrides() bool

+ func (a *Agent) HasTurnCheckpoints() bool

+ func (a *Agent) ImportState(data []byte) error

+ func (a *Agent) InjectInputContext(input string) error

+ func (a *Agent) InjectProactiveContext(ctx context.Context, query string) error

+ func (a *Agent) InjectWebUIManagers(approvalMgr *security.ApprovalManager, askUserMgr *tools.AskUserManager)

+ func (a *Agent) InterruptCtx() context.Context

+ func (a *Agent) IsChangeTrackingEnabled() bool

+ func (a *Agent) IsDebugMode() bool

+ func (a *Agent) IsEmbeddingIndexEnabled() bool

+ func (a *Agent) IsFolderSessionAllowed(absPath string) bool

+ func (a *Agent) IsInteractiveMode() bool

+ func (a *Agent) IsInterrupted() bool

+ func (a *Agent) IsLocalMode() bool

+ func (a *Agent) IsSecurityBypassApproved() bool

+ func (a *Agent) IsSessionElevated() bool

+ func (a *Agent) IsShellCommandAllowlisted(command string) bool

+ func (a *Agent) IsStreamingEnabled() bool

+ func (a *Agent) IsSubagent() bool

+ func (a *Agent) ListChanges(args map[string]interface{}) (string, error)

+ func (a *Agent) LoadState(sessionID string) (*ConversationState, error)

+ func (a *Agent) LoadStateFromFile(filename string) error

+ func (a *Agent) LoadStateScoped(sessionID, workingDir string) (*ConversationState, error)

+ func (a *Agent) LoadSummaryFromFile(filename string) error

+ func (a *Agent) LogToolCall(tc api.ToolCall, phase string)

+ func (a *Agent) Logger() *AgentLogger

+ func (a *Agent) MarkEstimatedTokenUsageResponse()

+ func (a *Agent) MaxSubagentDepth() int

+ func (a *Agent) MergeEventMetadata(extras map[string]interface{})

+ func (a *Agent) MyRecentChanges(since string) (string, error)

+ func (a *Agent) NavigateHistory(direction int, currentIndex int) (string, int)

+ func (a *Agent) OutputRouter() *OutputRouter

+ func (a *Agent) PersistShellCommandAllowlist(command string) error

+ func (a *Agent) PrintCompactProgress()

+ func (a *Agent) PrintConciseSummary()

+ func (a *Agent) PrintConversationSummary(forceFull bool)

+ func (a *Agent) PrintLine(text string)

+ func (a *Agent) PrintLineAsync(text string)

+ func (a *Agent) PrintTerminalOnly(text string)

+ func (a *Agent) ProcessQuery(userQuery string) (string, error)

+ func (a *Agent) ProcessQueryWithContinuity(userQuery string) (string, error)

+ func (a *Agent) PromptChoice(prompt string, choices []ChoiceOption) (string, error)

+ func (a *Agent) PublishAgentMessage(category, message string, extra map[string]interface{})

+ func (a *Agent) PublishFileChange(filePath, action, content string)

+ func (a *Agent) PublishQueryProgress(message string, iteration int, tokensUsed int)

+ func (a *Agent) PublishStreamChunk(chunk string, contentType string)

+ func (a *Agent) PublishTodoUpdate(todos []map[string]interface{})

+ func (a *Agent) PublishToolEnd(toolCallID, toolName, status, result, errorMessage string, ...)

+ func (a *Agent) PublishToolExecution(toolName, action string, details map[string]interface{})

+ func (a *Agent) PublishToolStart(toolName, toolCallID, arguments, displayName, persona string, isSubagent bool, ...)

+ func (a *Agent) ReadFileContent(path string) (string, error)

+ func (a *Agent) RecordFileReadThisTurn(path string)

+ func (a *Agent) RecordTurnCheckpoint(startIndex, endIndex int)

+ func (a *Agent) RecordTurnCheckpointAsync(startIndex, endIndex int)

+ func (a *Agent) RecoverFile(path string) (string, error)

+ func (a *Agent) RefreshMCPTools() error

+ func (a *Agent) ReplaceTurnCheckpoints(checkpoints []TurnCheckpoint)

+ func (a *Agent) ResetFileReadsForNewTurn()

+ func (a *Agent) ResetHistoryIndex()

+ func (a *Agent) RestoreEmbeddingIndex()

+ func (a *Agent) RevertMyChanges(scope, file, since string) (string, error)

+ func (a *Agent) SaveConversationSummary() error

+ func (a *Agent) SaveState(sessionID string) error

+ func (a *Agent) SaveStateScoped(sessionID, workingDir string) error

+ func (a *Agent) SaveStateToFile(filename string) error

+ func (a *Agent) SelectProvider() error

+ func (a *Agent) SetBackgroundProcessManager(bpm *tools.BackgroundProcessManager)

+ func (a *Agent) SetBaseSystemPrompt(prompt string)

+ func (a *Agent) SetConfigOverrides(overrides map[string]interface{})

+ func (a *Agent) SetConversationOptimization(enabled bool)

+ func (a *Agent) SetElevationGatePrompter()

+ func (a *Agent) SetEventBus(eventBus *events.EventBus)

+ func (a *Agent) SetEventMetadata(metadata map[string]interface{})

+ func (a *Agent) SetFileMetadata(path string, md WorkspaceFileMetadata)

+ func (a *Agent) SetFleetBudget(tracker *atomic.Int64, limit int64)

+ func (a *Agent) SetFlushCallback(callback func())

+ func (a *Agent) SetHasActiveWebUIClients(fn func() bool)

+ func (a *Agent) SetInterruptHandler(ch chan struct{})

+ func (a *Agent) SetLastPreparedToolNames(tools []api.Tool)

+ func (a *Agent) SetMaxIterations(max int)

+ func (a *Agent) SetMessages(messages []api.Message)

+ func (a *Agent) SetModel(model string) error

+ func (a *Agent) SetModelPersisted(model string) error

+ func (a *Agent) SetOutputMutex(mutex *sync.Mutex)

+ func (a *Agent) SetPreviousSummary(summary string)

+ func (a *Agent) SetProvider(provider api.ClientType) error

+ func (a *Agent) SetProviderPersisted(provider api.ClientType) error

+ func (a *Agent) SetPruningSlidingWindowSize(size int)

+ func (a *Agent) SetPruningStrategy(strategy PruningStrategy)

+ func (a *Agent) SetPruningThreshold(threshold float64)

+ func (a *Agent) SetRecentMessagesToKeep(count int)

+ func (a *Agent) SetRiskProfileOverride(profile configuration.RiskProfile)

+ func (a *Agent) SetSessionID(sessionID string)

+ func (a *Agent) SetSessionName(name string)

+ func (a *Agent) SetShellCommandHistoryEntry(command string, result *ShellCommandResult)

+ func (a *Agent) SetShellCwd(dir string)

+ func (a *Agent) SetStatsUpdateCallback(callback func(int, float64))

+ func (a *Agent) SetStreamingCallback(callback func(string))

+ func (a *Agent) SetStreamingEnabled(enabled bool)

+ func (a *Agent) SetSystemPrompt(prompt string)

+ func (a *Agent) SetSystemPromptFromFile(filePath string) error

+ func (a *Agent) SetTerminalManager(tm tools.TerminalAccess)

+ func (a *Agent) SetTraceSession(traceSession interface{})

+ func (a *Agent) SetUI(ui UI)

+ func (a *Agent) SetUnsafeMode(unsafe bool)

+ func (a *Agent) SetWorkspaceRoot(workspaceRoot string)

+ func (a *Agent) ShowColoredDiff(oldContent, newContent string, maxLines int)

+ func (a *Agent) ShowDropdown(items interface{}, options DropdownOptions) (interface{}, error)

+ func (a *Agent) ShowMyChange(path string) (string, error)

+ func (a *Agent) ShowQuickPrompt(prompt string, options []QuickOption, horizontal bool) (QuickOption, error)

+ func (a *Agent) Shutdown()

+ func (a *Agent) SnapshotSessionAllowedFolders() []string

+ func (a *Agent) SubagentDepth() int

+ func (a *Agent) SummarizeMySession() (string, error)

+ func (a *Agent) ToolLog(action string, target string)

+ func (a *Agent) TrackFileEdit(filePath string, originalContent string, newContent string) error

+ func (a *Agent) TrackFileWrite(filePath string, content string) error

+ func (a *Agent) TrackMetricsFromResponse(promptTokens, completionTokens, totalTokens int, estimatedCost float64, ...)

+ func (a *Agent) TriggerInterrupt()

+ type AgentLogger struct

+ func NewAgentLogger(agent *Agent) *AgentLogger

+ func (l *AgentLogger) Debug(format string, args ...interface{})

+ func (l *AgentLogger) Error(format string, args ...interface{})

+ func (l *AgentLogger) Info(format string, args ...interface{})

+ func (l *AgentLogger) SetJSONMode(jsonMode bool)

+ func (l *AgentLogger) Warn(format string, args ...interface{})

+ func (l *AgentLogger) WithFields(fields map[string]string) *LogContext

+ type AgentMCPManager struct

+ func NewAgentMCPManager() *AgentMCPManager

+ func (m *AgentMCPManager) GetInitError() error

+ func (m *AgentMCPManager) GetManager() mcp.MCPManager

+ func (m *AgentMCPManager) GetToolsCache() []api.Tool

+ func (m *AgentMCPManager) IsInitialized() bool

+ func (m *AgentMCPManager) LockInit()

+ func (m *AgentMCPManager) SetInitError(err error)

+ func (m *AgentMCPManager) SetInitialized(initialized bool)

+ func (m *AgentMCPManager) SetManager(mgr mcp.MCPManager)

+ func (m *AgentMCPManager) SetToolsCache(tools []api.Tool)

+ func (m *AgentMCPManager) UnlockInit()

+ type AgentOutputManager struct

+ func NewAgentOutputManager() *AgentOutputManager

+ func (m *AgentOutputManager) EnsureAsyncOutputWorker(fn func())

+ func (m *AgentOutputManager) GetAsyncBufferSize() int

+ func (m *AgentOutputManager) GetAsyncOutput() chan string

+ func (m *AgentOutputManager) GetEventMetadata() map[string]interface{}

+ func (m *AgentOutputManager) GetEventMetadataMutex() *sync.RWMutex

+ func (m *AgentOutputManager) GetFlushCallback() func()

+ func (m *AgentOutputManager) GetOutputMutex() *sync.Mutex

+ func (m *AgentOutputManager) GetOutputRouter() *OutputRouter

+ func (m *AgentOutputManager) GetReasoningBuffer() *strings.Builder

+ func (m *AgentOutputManager) GetReasoningCallback() func(string)

+ func (m *AgentOutputManager) GetStreamingBuffer() *strings.Builder

+ func (m *AgentOutputManager) GetStreamingCallback() func(string)

+ func (m *AgentOutputManager) GetTerminalWriter() func(string)

+ func (m *AgentOutputManager) IsStreamingEnabled() bool

+ func (m *AgentOutputManager) SetAsyncBufferSize(size int)

+ func (m *AgentOutputManager) SetAsyncOutput(ch chan string)

+ func (m *AgentOutputManager) SetEventMetadata(meta map[string]interface{})

+ func (m *AgentOutputManager) SetEventMetadataUnlocked(meta map[string]interface{})

+ func (m *AgentOutputManager) SetFlushCallback(cb func())

+ func (m *AgentOutputManager) SetOutputMutex(mu *sync.Mutex)

+ func (m *AgentOutputManager) SetOutputRouter(router *OutputRouter)

+ func (m *AgentOutputManager) SetReasoningCallback(cb func(string))

+ func (m *AgentOutputManager) SetStreamingCallback(cb func(string))

+ func (m *AgentOutputManager) SetStreamingEnabled(enabled bool)

+ func (m *AgentOutputManager) SetTerminalWriter(fn func(string))

+ type AgentSecurityManager struct

+ func NewAgentSecurityManager() *AgentSecurityManager

+ func (m *AgentSecurityManager) AddSessionAllowedFolder(folder string)

+ func (m *AgentSecurityManager) GetAskUserMgr() *agenttools.AskUserManager

+ func (m *AgentSecurityManager) GetElevationGate() *security.ElevationGate

+ func (m *AgentSecurityManager) GetOutputRedactor() *security.OutputRedactor

+ func (m *AgentSecurityManager) GetSecurityApprovalMgr() *security.ApprovalManager

+ func (m *AgentSecurityManager) GetUnsafeMode() bool

+ func (m *AgentSecurityManager) HasActiveWebUIClients() bool

+ func (m *AgentSecurityManager) IsConcernIgnored(filePath, concern string) bool

+ func (m *AgentSecurityManager) IsFolderSessionAllowed(absPath string) bool

+ func (m *AgentSecurityManager) IsSecurityBypassApproved() bool

+ func (m *AgentSecurityManager) SetApprovalMgr(mgr *security.ApprovalManager)

+ func (m *AgentSecurityManager) SetAskUserMgr(mgr *agenttools.AskUserManager)

+ func (m *AgentSecurityManager) SetConcernIgnored(filePath, concern string)

+ func (m *AgentSecurityManager) SetElevationGate(gate *security.ElevationGate)

+ func (m *AgentSecurityManager) SetHasActiveWebUIClients(fn func() bool)

+ func (m *AgentSecurityManager) SetUnsafeMode(unsafe bool)

+ func (m *AgentSecurityManager) SnapshotSessionAllowedFolders() []string

+ type AgentState struct

+ CachedCostSavings float64

+ CachedTokens int

+ CompactSummary string

+ CompletionTokens int

+ EstimatedTokenResponses int

+ Messages []api.Message

+ PreviousSummary string

+ PromptTokens int

+ SessionID string

+ TaskActions []TaskAction

+ TotalCost float64

+ TotalTokens int

+ TurnCheckpoints []TurnCheckpoint

+ type AgentStateManager struct

+ func NewAgentStateManager(debug bool) *AgentStateManager

+ func (s *AgentStateManager) AddCost(c float64)

+ func (s *AgentStateManager) AddMessage(msg api.Message)

+ func (s *AgentStateManager) AddTaskAction(action TaskAction)

+ func (s *AgentStateManager) AddTurnCheckpoint(cp TurnCheckpoint)

+ func (s *AgentStateManager) GetActivePersona() string

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

+ func (s *AgentStateManager) GetCachedCostSavings() float64

+ func (s *AgentStateManager) GetCachedTokens() int

+ func (s *AgentStateManager) GetCheckpointMutex() *sync.RWMutex

+ func (s *AgentStateManager) GetCircuitBreaker() *CircuitBreakerState

+ func (s *AgentStateManager) GetCommandHistory() []string

+ func (s *AgentStateManager) GetCompletionTokens() int

+ func (s *AgentStateManager) GetConfigOverrides() map[string]interface{}

+ func (s *AgentStateManager) GetConversationPruner() *ConversationPruner

+ func (s *AgentStateManager) GetCurrentContextTokens() int

+ func (s *AgentStateManager) GetCurrentIteration() int

+ func (s *AgentStateManager) GetEstimatedTokenResponses() int

+ func (s *AgentStateManager) GetHistoryIndex() int

+ func (s *AgentStateManager) GetHistoryMutex() *sync.Mutex

+ func (s *AgentStateManager) GetLLMCallCount() int

+ func (s *AgentStateManager) GetLastProviderError() *ProviderErrorInfo

+ func (s *AgentStateManager) GetLastRunTerminationReason() string

+ func (s *AgentStateManager) GetMaxContextTokens() int

+ func (s *AgentStateManager) GetMessages() []api.Message

+ func (s *AgentStateManager) GetOptimizer() *ConversationOptimizer

+ func (s *AgentStateManager) GetPauseMutex() *sync.Mutex

+ func (s *AgentStateManager) GetPauseState() *PauseState

+ func (s *AgentStateManager) GetPendingStrictSwitchNotice() string

+ func (s *AgentStateManager) GetPendingSwitchContextRefresh() string

+ func (s *AgentStateManager) GetPendingSystemSupplement() string

+ func (s *AgentStateManager) GetPreviousSummary() string

+ func (s *AgentStateManager) GetPromptTokens() int

+ func (s *AgentStateManager) GetSessionID() string

+ func (s *AgentStateManager) GetSessionIntentEmbedding() []float32

+ func (s *AgentStateManager) GetSessionModel() string

+ func (s *AgentStateManager) GetSessionProvider() api.ClientType

+ func (s *AgentStateManager) GetTaskActions() []TaskAction

+ func (s *AgentStateManager) GetTaskActionsMutex() *sync.RWMutex

+ func (s *AgentStateManager) GetTotalCost() float64

+ func (s *AgentStateManager) GetTotalTokens() int

+ func (s *AgentStateManager) GetTotalToolCalls() int

+ func (s *AgentStateManager) GetTraceSession() interface{}

+ func (s *AgentStateManager) GetTurnCheckpoints() []TurnCheckpoint

+ func (s *AgentStateManager) IncrementLLMCallCount()

+ func (s *AgentStateManager) IncrementTotalToolCalls()

+ func (s *AgentStateManager) IsContextWarningIssued() bool

+ func (s *AgentStateManager) IsFalseStopDetectionEnabled() bool

+ func (s *AgentStateManager) IsToolCallGuidanceAdded() bool

+ func (s *AgentStateManager) SetActivePersona(p string)

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

+ func (s *AgentStateManager) SetCachedCostSavings(c float64)

+ func (s *AgentStateManager) SetCachedTokens(n int)

+ func (s *AgentStateManager) SetCircuitBreaker(cb *CircuitBreakerState)

+ func (s *AgentStateManager) SetCommandHistory(h []string)

+ func (s *AgentStateManager) SetCompletionTokens(n int)

+ func (s *AgentStateManager) SetConfigOverrides(overrides map[string]interface{})

+ func (s *AgentStateManager) SetContextWarningIssued(v bool)

+ func (s *AgentStateManager) SetConversationPruner(pruner *ConversationPruner)

+ func (s *AgentStateManager) SetCurrentContextTokens(n int)

+ func (s *AgentStateManager) SetCurrentIteration(iter int)

+ func (s *AgentStateManager) SetEstimatedTokenResponses(n int)

+ func (s *AgentStateManager) SetFalseStopDetectionEnabled(v bool)

+ func (s *AgentStateManager) SetHistoryIndex(i int)

+ func (s *AgentStateManager) SetLLMCallCount(n int)

+ func (s *AgentStateManager) SetLastProviderError(err *ProviderErrorInfo)

+ func (s *AgentStateManager) SetLastRunTerminationReason(reason string)

+ func (s *AgentStateManager) SetMaxContextTokens(n int)

+ func (s *AgentStateManager) SetMessages(msgs []api.Message)

+ func (s *AgentStateManager) SetOptimizer(o *ConversationOptimizer)

+ func (s *AgentStateManager) SetPauseState(ps *PauseState)

+ func (s *AgentStateManager) SetPendingStrictSwitchNotice(v string)

+ func (s *AgentStateManager) SetPendingSwitchContextRefresh(v string)

+ func (s *AgentStateManager) SetPendingSystemSupplement(v string)

+ func (s *AgentStateManager) SetPreviousSummary(summary string)

+ func (s *AgentStateManager) SetPromptTokens(n int)

+ func (s *AgentStateManager) SetSessionID(id string)

+ func (s *AgentStateManager) SetSessionIntentEmbedding(emb []float32)

+ func (s *AgentStateManager) SetSessionIntentEmbeddingIfNil(emb []float32) bool

+ func (s *AgentStateManager) SetSessionModel(m string)

+ func (s *AgentStateManager) SetSessionProvider(ct api.ClientType)

+ func (s *AgentStateManager) SetTaskActions(actions []TaskAction)

+ func (s *AgentStateManager) SetToolCallGuidanceAdded(v bool)

+ func (s *AgentStateManager) SetTotalCost(c float64)

+ func (s *AgentStateManager) SetTotalTokens(n int)

+ func (s *AgentStateManager) SetTotalToolCalls(n int)

+ func (s *AgentStateManager) SetTraceSession(ts interface{})

+ func (s *AgentStateManager) SetTurnCheckpoints(cps []TurnCheckpoint)

+ type ChangeTracker struct

+ func NewChangeTracker(agent *Agent, instructions string) *ChangeTracker

+ func (ct *ChangeTracker) Clear()

+ func (ct *ChangeTracker) CollectFileChangesForCheckpoint() ([]CheckpointFileChange, string)

+ func (ct *ChangeTracker) Commit(llmResponse string, conversation []api.Message) error

+ func (ct *ChangeTracker) Disable()

+ func (ct *ChangeTracker) Enable()

+ func (ct *ChangeTracker) GenerateAISummary() (string, error)

+ func (ct *ChangeTracker) GetChangeCount() int

+ func (ct *ChangeTracker) GetChanges() []TrackedFileChange

+ func (ct *ChangeTracker) GetRevisionID() string

+ func (ct *ChangeTracker) GetSummary() string

+ func (ct *ChangeTracker) GetTrackedFiles() []string

+ func (ct *ChangeTracker) IsEnabled() bool

+ func (ct *ChangeTracker) PrimeShellTracking(workDir string)

+ func (ct *ChangeTracker) RecordShellMutations(before, after map[string]*shellSnapshotEntry, toolCall string)

+ func (ct *ChangeTracker) Reset(instructions string)

+ func (ct *ChangeTracker) SyncShellCacheForPath(path string)

+ func (ct *ChangeTracker) TrackFileEdit(filePath string, originalContent string, newContent string) error

+ func (ct *ChangeTracker) TrackFileWrite(filePath string, newContent string) error

+ func (ct *ChangeTracker) TrackShellTurn(workDir, toolCall string)

+ type CheckpointFileChange struct

+ Op string

+ Path string

+ type ChoiceOption struct

+ Label string

+ Value string

+ type CircuitBreakerAction struct

+ ActionType string

+ Count int

+ LastUsed int64

+ Target string

+ type CircuitBreakerState struct

+ Actions map[string]*CircuitBreakerAction

+ type ClarificationManager struct

+ func NewClarificationManager(eventBus *events.EventBus) *ClarificationManager

+ func NewClarificationManagerWithTimeout(eventBus *events.EventBus, timeout time.Duration) *ClarificationManager

+ func (m *ClarificationManager) Cleanup()

+ func (m *ClarificationManager) Close()

+ func (m *ClarificationManager) GetPendingClarifications(delegateID string) []ClarificationRequest

+ func (m *ClarificationManager) RequestClarification(ctx context.Context, delegateID, question string) (string, error)

+ func (m *ClarificationManager) RespondClarification(requestID, response string) error

+ type ClarificationRequest struct

+ CreatedAt time.Time

+ DelegateID string

+ Question string

+ RequestID string

+ type ContextFileInfo struct

+ Content string

+ Description string

+ Path string

+ Priority int

+ func DiscoverContextFiles() (*ContextFileInfo, error)

+ type ConversationOptimizer struct

+ func NewConversationOptimizer(enabled, debug bool) *ConversationOptimizer

+ func (co *ConversationOptimizer) CompactConversation(messages []api.Message) []api.Message

+ func (co *ConversationOptimizer) GetOptimizationStats() map[string]interface{}

+ func (co *ConversationOptimizer) Inner() *core.ConversationOptimizer

+ func (co *ConversationOptimizer) InvalidateFile(filePath string)

+ func (co *ConversationOptimizer) IsEnabled() bool

+ func (co *ConversationOptimizer) OptimizeConversation(messages []api.Message) []api.Message

+ func (co *ConversationOptimizer) Reset()

+ func (co *ConversationOptimizer) SetEnabled(enabled bool)

+ func (co *ConversationOptimizer) SetLLMClient(client api.ClientInterface, provider string, printLine func(string))

+ type ConversationPruner = core.ConversationPruner

+ type ConversationState struct

+ CachedCostSavings float64

+ CachedTokens int

+ CompletionTokens int

+ ConfigOverrides map[string]interface{}

+ EstimatedTokenResponses int

+ LastProviderError *ProviderErrorInfo

+ LastUpdated time.Time

+ Messages []api.Message

+ Name string

+ PromptTokens int

+ SessionID string

+ SessionIntentEmbedding []float32

+ TaskActions []TaskAction

+ TotalCost float64

+ TotalTokens int

+ TurnCheckpoints []TurnCheckpoint

+ WorkingDirectory string

+ func ImportStateFromJSONFile(filename string) (*ConversationState, error)

+ func LoadSessionInfo(sessionID string) (*ConversationState, error)

+ func LoadStateWithoutAgent(sessionID string) (*ConversationState, error)

+ func LoadStateWithoutAgentScoped(sessionID, workingDir string) (*ConversationState, error)

+ type ConversationTurn struct

+ ActionableSummary string

+ Duration float64

+ FilesTouched []string

+ ID string

+ PromptEmbedding []float32

+ SessionID string

+ Timestamp time.Time

+ TokenUsage int

+ TurnNumber int

+ UserPrompt string

+ WorkingDir string

+ func NewConversationTurn(sessionID string, turnNumber int, userPrompt, workingDir string) (*ConversationTurn, error)

+ func (t *ConversationTurn) String() string

+ func (t *ConversationTurn) ToVectorRecord() embedding.VectorRecord

+ type DiffChange struct

+ NewLength int

+ NewStart int

+ OldLength int

+ OldStart int

+ type DriftDetector struct

+ func NewDriftDetector(threshold float64, checkInterval int) *DriftDetector

+ func (d *DriftDetector) CheckDrift(sessionIntent []float32, currentEmbedding []float32) (isDrift bool, similarity float64)

+ func (d *DriftDetector) DriftCount() int

+ func (d *DriftDetector) IsSuppressed() bool

+ func (d *DriftDetector) RecordAcceptance()

+ func (d *DriftDetector) RecordDrift()

+ func (d *DriftDetector) RecordRejection()

+ func (d *DriftDetector) RejectionCount() int

+ func (d *DriftDetector) ShouldCheck(turnNumber int) bool

+ type DriftNotification struct

+ func NewDriftNotification(detector *DriftDetector, eventBus *events.EventBus, sessionID string) *DriftNotification

+ func (n *DriftNotification) NotifyDrift(similarity float64, threshold float64) map[string]interface{}

+ type DropdownItem struct

+ Label string

+ Value string

+ type DropdownOptions struct

+ Prompt string

+ SearchPrompt string

+ ShowCounts bool

+ type FileChange struct

+ Op string

+ Path string

+ type LogContext struct

+ func (lc *LogContext) Debug(format string, args ...interface{})

+ func (lc *LogContext) Error(format string, args ...interface{})

+ func (lc *LogContext) Info(format string, args ...interface{})

+ func (lc *LogContext) Warn(format string, args ...interface{})

+ type LogEntry struct

+ Fields map[string]string

+ Iteration int

+ Level string

+ Message string

+ Model string

+ Provider string

+ SessionID string

+ Timestamp string

+ type MCPSubManager interface

+ GetInitError func() error

+ GetManager func() mcp.MCPManager

+ GetToolsCache func() []api.Tool

+ IsInitialized func() bool

+ LockInit func()

+ SetInitError func(err error)

+ SetInitialized func(initialized bool)

+ SetManager func(mgr mcp.MCPManager)

+ SetToolsCache func(tools []api.Tool)

+ UnlockInit func()

+ type MemoryInfo struct

+ Content string

+ Name string

+ Path string

+ func ListMemories() ([]MemoryInfo, error)

+ func LoadAllMemories() ([]MemoryInfo, error)

+ type MessageImportance = core.MessageImportance

+ type ModelItem struct

+ ContextLength int

+ InputCost float64

+ Label string

+ LegacyCost float64

+ Model string

+ OutputCost float64

+ Provider string

+ Tags []string

+ Value string

+ type OutputBuffer struct

+ func NewOutputBuffer() *OutputBuffer

+ func (ob *OutputBuffer) Clear()

+ func (ob *OutputBuffer) GetAndClear() string

+ func (ob *OutputBuffer) GetOutput() string

+ func (ob *OutputBuffer) Print(args ...interface{})

+ func (ob *OutputBuffer) Printf(format string, args ...interface{})

+ func (ob *OutputBuffer) Println(args ...interface{})

+ type OutputManager interface

+ EnsureAsyncOutputWorker func(fn func())

+ GetAsyncBufferSize func() int

+ GetAsyncOutput func() chan string

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

+ GetEventMetadataMutex func() *sync.RWMutex

+ GetFlushCallback func() func()

+ GetOutputMutex func() *sync.Mutex

+ GetOutputRouter func() *OutputRouter

+ GetReasoningBuffer func() *strings.Builder

+ GetReasoningCallback func() func(string)

+ GetStreamingBuffer func() *strings.Builder

+ GetStreamingCallback func() func(string)

+ GetTerminalWriter func() func(string)

+ IsStreamingEnabled func() bool

+ SetAsyncBufferSize func(size int)

+ SetAsyncOutput func(ch chan string)

+ SetEventMetadata func(meta map[string]interface{})

+ SetEventMetadataUnlocked func(meta map[string]interface{})

+ SetFlushCallback func(cb func())

+ SetOutputMutex func(mu *sync.Mutex)

+ SetOutputRouter func(router *OutputRouter)

+ SetReasoningCallback func(cb func(string))

+ SetStreamingCallback func(cb func(string))

+ SetStreamingEnabled func(enabled bool)

+ SetTerminalWriter func(fn func(string))

+ type OutputMode int

+ const OutputModeEventSourced

+ const OutputModeTerminal

+ type OutputRouter struct

+ func NewOutputRouter(agent *Agent, eventBus *events.EventBus) *OutputRouter

+ func (r *OutputRouter) Mode() OutputMode

+ func (r *OutputRouter) RouteAgentMessage(category, message string, extra map[string]interface{})

+ func (r *OutputRouter) RouteStreamChunk(chunk string, contentType string)

+ func (r *OutputRouter) RouteTerminalOnly(message string)

+ func (r *OutputRouter) RouteToolCompletion(ok bool, duration time.Duration, errMsg string)

+ func (r *OutputRouter) RouteToolLog(action string, target string)

+ func (r *OutputRouter) SetEventBus(eventBus *events.EventBus)

+ func (r *OutputRouter) SetExternalWriteHook(fn func())

+ func (r *OutputRouter) SetReasoningTerminalEnabled(enabled bool)

+ type ParameterConfig struct

+ Alternatives []string

+ Description string

+ Name string

+ Required bool

+ Type string

+ type PathTier int

+ const PathTierExternal

+ const PathTierSensitive

+ const PathTierUnknown

+ const PathTierWorkspace

+ func ClassifyPathAccess(path, workspaceRoot, homeDir, cwd string) PathTier

+ func (t PathTier) String() string

+ type PauseState struct

+ Clarifications []string

+ IsPaused bool

+ MessagesBefore []api.Message

+ OriginalTask string

+ PausedAt time.Time

+ type ProactiveContextConfig struct

+ MaxContextChars int

+ MaxContextualResults int

+ MinRelevanceScore float64

+ RetentionDays int

+ WorkspaceScoped bool

+ func DefaultProactiveContextConfig() ProactiveContextConfig

+ type ProactiveContextResult struct

+ Record embedding.VectorRecord

+ Score float64

+ func RetrieveProactiveContext(ctx context.Context, mgr *embedding.EmbeddingManager, ...) ([]ProactiveContextResult, error)

+ type ProgressEntry struct

+ Message string

+ OffsetMS int64

+ Phase string

+ type ProjectInfo struct

+ Description string

+ HasAgentsMd bool

+ HasGitRepo bool

+ Languages []string

+ Name string

+ Path string

+ RelPath string

+ func DiscoverProjects(homeDir string, maxDepth int) ([]ProjectInfo, error)

+ type PromptTokensDetails struct

+ CacheWriteTokens *int

+ CachedTokens int

+ type ProviderErrorInfo struct

+ ErrorType string

+ Message string

+ Model string

+ Provider string

+ Retries int

+ StatusCode int

+ Timestamp string

+ type PruningStrategy = core.PruningStrategy

+ type QuickOption struct

+ Label string

+ Value string

+ type RateLimitExceededError struct

+ Attempts int

+ LastError error

+ func (e *RateLimitExceededError) Error() string

+ func (e *RateLimitExceededError) Unwrap() error

+ type ReconciliationActionResult struct

+ Action ReconciliationActionType

+ BrowserSeq int64

+ ContainerSeq int64

+ FilePath string

+ func ReconcileSeqNumbers(ag *Agent, browserSeqs map[string]int64) ([]ReconciliationActionResult, error)

+ type ReconciliationActionType string

+ const ReconcileBrowserAhead

+ const ReconcileContainerAhead

+ const ReconcileDiverged

+ const ReconcileSyncOK

+ type RetryAction int

+ const ActionEscalate

+ const ActionFail

+ const ActionRetry

+ func ClassifyError(err error) RetryAction

+ func (a RetryAction) String() string

+ type ScriptedClient struct

+ func NewScriptedClient(responses ...*ScriptedResponse) *ScriptedClient

+ func NewScriptedClientWithVision(model string, responses ...*ScriptedResponse) *ScriptedClient

+ func (c *ScriptedClient) AddResponse(response *ScriptedResponse)

+ func (c *ScriptedClient) AdvanceIndex()

+ func (c *ScriptedClient) Cancel()

+ func (c *ScriptedClient) CheckConnection() error

+ func (c *ScriptedClient) ClearHistory()

+ func (c *ScriptedClient) ClearSentRequests()

+ func (c *ScriptedClient) Close()

+ func (c *ScriptedClient) GetAverageTPS() float64

+ func (c *ScriptedClient) GetIndex() int

+ func (c *ScriptedClient) GetLastTPS() float64

+ func (c *ScriptedClient) GetModel() string

+ func (c *ScriptedClient) GetModelContextLimit() (int, error)

+ func (c *ScriptedClient) GetNextResponse() *ScriptedResponse

+ func (c *ScriptedClient) GetProvider() string

+ func (c *ScriptedClient) GetSentRequest(index int) []api.Message

+ func (c *ScriptedClient) GetSentRequests() [][]api.Message

+ func (c *ScriptedClient) GetTPSStats() map[string]float64

+ func (c *ScriptedClient) GetVisionModel() string

+ func (c *ScriptedClient) LastResponse() *ScriptedResponse

+ func (c *ScriptedClient) Length() int

+ func (c *ScriptedClient) ListModels(ctx context.Context) ([]api.ModelInfo, error)

+ func (c *ScriptedClient) Reset()

+ func (c *ScriptedClient) ResetTPSStats()

+ func (c *ScriptedClient) ResponseHistory() []*ScriptedResponse

+ func (c *ScriptedClient) SendChatRequest(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (c *ScriptedClient) SendChatRequestStream(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (c *ScriptedClient) SendVisionRequest(ctx context.Context, messages []api.Message, tools []api.Tool, ...) (*api.ChatResponse, error)

+ func (c *ScriptedClient) SetDebug(debug bool)

+ func (c *ScriptedClient) SetIndex(idx int)

+ func (c *ScriptedClient) SetModel(model string) error

+ func (c *ScriptedClient) SetResponses(responses []*ScriptedResponse)

+ func (c *ScriptedClient) SupportsVision() bool

+ type ScriptedResponse struct

+ Content string

+ Delay time.Duration

+ Error error

+ FinishReason string

+ Images []api.ImageData

+ RateLimitAfter int

+ ReasoningContent string

+ StreamConfig *StreamConfig

+ ToolCalls []api.ToolCall

+ Usage ScriptedTokenUsage

+ VisionOnly bool

+ func NewErrorResponse(err error) *ScriptedResponse

+ func NewKeepGoingResponse(content string) *ScriptedResponse

+ func NewLengthResponse(content string) *ScriptedResponse

+ func NewRateLimitResponse() *ScriptedResponse

+ func NewStopResponse(content string) *ScriptedResponse

+ func NewTimeoutResponse() *ScriptedResponse

+ func NewToolCallResponse(name, args string, toolCalls ...api.ToolCall) *ScriptedResponse

+ type ScriptedResponseBuilder struct

+ func NewScriptedResponseBuilder() *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) Build() *ScriptedResponse

+ func (b *ScriptedResponseBuilder) Content(content string) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) Delay(d time.Duration) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) Error(err error) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) FinishReason(reason string) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) Images(images []api.ImageData) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) RateLimitAfter(n int) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) ReasoningContent(content string) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) StreamConfig(sc *StreamConfig) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) ToolCall(tc api.ToolCall) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) ToolCalls(tcs []api.ToolCall) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) Usage(promptTokens, completionTokens, totalTokens int, estimatedCost float64) *ScriptedResponseBuilder

+ func (b *ScriptedResponseBuilder) VisionOnly() *ScriptedResponseBuilder

+ type ScriptedTokenUsage struct

+ CompletionTokens int

+ Cost float64

+ EstimatedCost float64

+ PromptTokens int

+ PromptTokensDetails PromptTokensDetails

+ TotalTokens int

+ type SecurityManager interface

+ AddSessionAllowedFolder func(folder string)

+ GetAskUserMgr func() *agenttools.AskUserManager

+ GetElevationGate func() *security.ElevationGate

+ GetOutputRedactor func() *security.OutputRedactor

+ GetSecurityApprovalMgr func() *security.ApprovalManager

+ GetUnsafeMode func() bool

+ HasActiveWebUIClients func() bool

+ IsConcernIgnored func(filePath, concern string) bool

+ IsFolderSessionAllowed func(absPath string) bool

+ IsSecurityBypassApproved func() bool

+ SetApprovalMgr func(mgr *security.ApprovalManager)

+ SetAskUserMgr func(mgr *agenttools.AskUserManager)

+ SetConcernIgnored func(filePath, concern string)

+ SetElevationGate func(gate *security.ElevationGate)

+ SetHasActiveWebUIClients func(fn func() bool)

+ SetUnsafeMode func(unsafe bool)

+ SnapshotSessionAllowedFolders func() []string

+ type SessionInfo struct

+ LastUpdated time.Time

+ Name string

+ SessionID string

+ StoragePath string

+ WorkingDirectory string

+ func ListAllSessionsWithTimestamps() ([]SessionInfo, error)

+ func ListSessionsWithTimestamps() ([]SessionInfo, error)

+ func ListSessionsWithTimestampsScoped(workingDir string) ([]SessionInfo, error)

+ type SessionItem struct

+ Label string

+ LastUpdated time.Time

+ Model string

+ Name string

+ SessionID string

+ Value string

+ type SharedState struct

+ ConfigManager *configuration.Manager

+ EmbeddingMgr *embedding.EmbeddingManager

+ EventBus *events.EventBus

+ TodoManager *tools.TodoManager

+ WorkspaceRoot string

+ type ShellCommandResult struct

+ Command string

+ Error error

+ ExecutedAt int64

+ FullOutput string

+ FullOutputPath string

+ MessageIndex int

+ TruncatedLines int

+ TruncatedOutput string

+ TruncatedTokens int

+ WasTruncated bool

+ type SimpleUI struct

+ func NewSimpleUI() *SimpleUI

+ func (s *SimpleUI) IsInteractive() bool

+ func (s *SimpleUI) ShowDropdown(ctx context.Context, items interface{}, options DropdownOptions) (interface{}, error)

+ func (s *SimpleUI) ShowQuickPrompt(ctx context.Context, prompt string, options []QuickOption, horizontal bool) (QuickOption, error)

+ type SkillInfo struct

+ Content string

+ Description string

+ ID string

+ Name string

+ Path string

+ Source string

+ func ListSkills(config *configuration.Config) []SkillInfo

+ func LoadSkill(skillID string, config *configuration.Config) (*SkillInfo, error)

+ type StateManager interface

+ AddCost func(float64)

+ AddMessage func(api.Message)

+ AddTaskAction func(TaskAction)

+ AddTurnCheckpoint func(TurnCheckpoint)

+ GetActivePersona func() string

+ GetActiveSkills func() []string

+ GetCachedCostSavings func() float64

+ GetCachedTokens func() int

+ GetCheckpointMutex func() *sync.RWMutex

+ GetCircuitBreaker func() *CircuitBreakerState

+ GetCommandHistory func() []string

+ GetCompletionTokens func() int

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

+ GetConversationPruner func() *ConversationPruner

+ GetCurrentContextTokens func() int

+ GetCurrentIteration func() int

+ GetEstimatedTokenResponses func() int

+ GetHistoryIndex func() int

+ GetHistoryMutex func() *sync.Mutex

+ GetLLMCallCount func() int

+ GetLastProviderError func() *ProviderErrorInfo

+ GetLastRunTerminationReason func() string

+ GetMaxContextTokens func() int

+ GetMessages func() []api.Message

+ GetOptimizer func() *ConversationOptimizer

+ GetPauseMutex func() *sync.Mutex

+ GetPauseState func() *PauseState

+ GetPendingStrictSwitchNotice func() string

+ GetPendingSwitchContextRefresh func() string

+ GetPendingSystemSupplement func() string

+ GetPreviousSummary func() string

+ GetPromptTokens func() int

+ GetSessionID func() string

+ GetSessionIntentEmbedding func() []float32

+ GetSessionModel func() string

+ GetSessionProvider func() api.ClientType

+ GetTaskActions func() []TaskAction

+ GetTaskActionsMutex func() *sync.RWMutex

+ GetTotalCost func() float64

+ GetTotalTokens func() int

+ GetTotalToolCalls func() int

+ GetTraceSession func() interface{}

+ GetTurnCheckpoints func() []TurnCheckpoint

+ IncrementLLMCallCount func()

+ IncrementTotalToolCalls func()

+ IsContextWarningIssued func() bool

+ IsFalseStopDetectionEnabled func() bool

+ IsToolCallGuidanceAdded func() bool

+ SetActivePersona func(string)

+ SetActiveSkills func([]string)

+ SetCachedCostSavings func(float64)

+ SetCachedTokens func(int)

+ SetCircuitBreaker func(*CircuitBreakerState)

+ SetCommandHistory func([]string)

+ SetCompletionTokens func(int)

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

+ SetContextWarningIssued func(bool)

+ SetConversationPruner func(*ConversationPruner)

+ SetCurrentContextTokens func(int)

+ SetCurrentIteration func(int)

+ SetEstimatedTokenResponses func(int)

+ SetFalseStopDetectionEnabled func(bool)

+ SetHistoryIndex func(int)

+ SetLLMCallCount func(int)

+ SetLastProviderError func(*ProviderErrorInfo)

+ SetLastRunTerminationReason func(string)

+ SetMaxContextTokens func(int)

+ SetMessages func([]api.Message)

+ SetOptimizer func(*ConversationOptimizer)

+ SetPauseState func(*PauseState)

+ SetPendingStrictSwitchNotice func(string)

+ SetPendingSwitchContextRefresh func(string)

+ SetPendingSystemSupplement func(string)

+ SetPreviousSummary func(string)

+ SetPromptTokens func(int)

+ SetSessionID func(string)

+ SetSessionIntentEmbedding func([]float32)

+ SetSessionIntentEmbeddingIfNil func(emb []float32) bool

+ SetSessionModel func(string)

+ SetSessionProvider func(api.ClientType)

+ SetTaskActions func([]TaskAction)

+ SetToolCallGuidanceAdded func(bool)

+ SetTotalCost func(float64)

+ SetTotalTokens func(int)

+ SetTotalToolCalls func(int)

+ SetTraceSession func(interface{})

+ SetTurnCheckpoints func([]TurnCheckpoint)

+ type StreamConfig struct

+ ChunkDelay time.Duration

+ ChunkErrors []error

+ Chunks []string

+ ErrorAfterChunks int

+ FinishReason string

+ StreamError error

+ TokensPerChunk int

+ type SubagentError struct

+ Reason string

+ Status SubagentStatus

+ func (e *SubagentError) Error() string

+ type SubagentMetrics struct

+ Active int64

+ Cancelled int64

+ Completed int64

+ Failed int64

+ Queued int64

+ TotalQueuedWaitMS int64

+ type SubagentOptions struct

+ FleetTokenBudget int

+ MaxConcurrentSubagents int

+ MaxTokens int

+ Model string

+ Persona string

+ Provider string

+ SystemPrompt string

+ Timeout time.Duration

+ WorkingDir string

+ type SubagentProgressEntry struct

+ Message string

+ OffsetMS int64

+ Phase string

+ type SubagentResult struct

+ BudgetExceeded bool

+ Cancelled bool

+ Cost float64

+ Elapsed time.Duration

+ Error error

+ FileChanges []TrackedFileChange

+ ID string

+ Iterations int

+ Output string

+ ProgressLog []SubagentProgressEntry

+ TokensUsed int

+ ToolCalls int

+ Truncated bool

+ type SubagentReturn struct

+ BudgetExceeded string

+ Completed string

+ ContextUsed string

+ Cost string

+ ElapsedSeconds string

+ ErrorReason string

+ ExitCode string

+ FilesModified []FileChange

+ FilesUsed string

+ Metrics SubagentRunMetrics

+ Output string

+ ProgressLog []ProgressEntry

+ Status SubagentStatus

+ Stderr string

+ Summary string

+ TimedOut string

+ TokensUsed string

+ ToolCallCount string

+ WorkingDir string

+ func (r *SubagentReturn) MarshalJSONIndent() (string, error)

+ type SubagentRunMetrics struct

+ Cost float64

+ Iterations int

+ TokensUsed int

+ ToolCalls int

+ type SubagentRunner struct

+ func NewSubagentRunner(parent *Agent, shared *SharedState) *SubagentRunner

+ func (r *SubagentRunner) CancelAll()

+ func (r *SubagentRunner) CancelSubagent(id string) bool

+ func (r *SubagentRunner) GetActiveSubagents() []*runningSubagent

+ func (r *SubagentRunner) InjectInputIntoActive(input string) (string, bool)

+ func (r *SubagentRunner) Metrics() SubagentMetrics

+ func (r *SubagentRunner) Run(ctx context.Context, prompt string, opts SubagentOptions) *SubagentResult

+ func (r *SubagentRunner) RunParallel(ctx context.Context, tasks []SubagentTask, opts SubagentOptions) []*SubagentResult

+ type SubagentStatus string

+ const SubagentStatusBudgetExceeded

+ const SubagentStatusCancelled

+ const SubagentStatusCompleted

+ const SubagentStatusFailed

+ const SubagentStatusSecurityBlocked

+ const SubagentStatusTimedOut

+ type SubagentTask struct

+ ID string

+ Model string

+ Persona string

+ Prompt string

+ Provider string

+ WorkingDir string

+ type SyncOp struct

+ BrowserSeq int64

+ Content string

+ NewPath string

+ OpType string

+ Path string

+ Timestamp int64

+ type SyncOpResult struct

+ Accepted bool

+ ConflictPath string

+ ContainerSeq int64

+ Error string

+ type TaskAction struct

+ Description string

+ Details string

+ Type string

+ type Theme struct

+ Colors struct{ ... }

+ Description string

+ Name string

+ type ThemeManager struct

+ func NewThemeManager() *ThemeManager

+ func (tm *ThemeManager) GetColor(name string) string

+ func (tm *ThemeManager) GetTheme() Theme

+ func (tm *ThemeManager) LoadDefaultTheme()

+ func (tm *ThemeManager) LoadThemeFromFile(themePath string) error

+ type TokenUsage struct

+ CompletionTokens int

+ EstimatedCost float64

+ PromptTokens int

+ TotalTokens int

+ type ToolConfig struct

+ Aliases []string

+ Description string

+ Handler ToolHandler

+ HandlerImages ToolHandlerWithImages

+ Interactive bool

+ MaxResultSize int

+ Name string

+ Parameters []ParameterConfig

+ SafeForParallel bool

+ Timeout time.Duration

+ type ToolExecutor struct

+ func NewToolExecutor(agent *Agent) *ToolExecutor

+ func (te *ToolExecutor) ExecuteTools(toolCalls []api.ToolCall) []api.Message

+ func (te *ToolExecutor) GenerateToolCallID(toolName string) string

+ func (te *ToolExecutor) SetHandlerRegistry(r *tools.ToolRegistry)

+ type ToolHandler func(ctx context.Context, a *Agent, args map[string]interface{}) (string, error)

+ type ToolHandlerWithImages func(ctx context.Context, a *Agent, args map[string]interface{}) ([]api.ImageData, string, error)

+ type ToolRegistry struct

+ func GetToolRegistry() *ToolRegistry

+ func (r *ToolRegistry) ExecuteTool(ctx context.Context, toolName string, args map[string]interface{}, ...) ([]api.ImageData, string, error)

+ func (r *ToolRegistry) GetAllToolConfigs() map[string]ToolConfig

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

+ func (r *ToolRegistry) GetToolConfig(name string) (ToolConfig, bool)

+ func (r *ToolRegistry) IsInteractive(name string) bool

+ func (r *ToolRegistry) RegisterTool(config ToolConfig)

+ type TrackedFileChange struct

+ FilePath string

+ NewCode string

+ Operation string

+ OriginalCode string

+ Timestamp time.Time

+ ToolCall string

+ type TurnCheckpoint struct

+ ActionableSummary string

+ EndIndex int

+ FileChanges []CheckpointFileChange

+ RevisionID string

+ StartIndex int

+ Summary string

+ type TurnEvaluation struct

+ AssistantContent string

+ CompletionReached bool

+ FinishReason string

+ GuardrailTrigger string

+ Iteration int

+ ReasoningSnippet string

+ Timestamp time.Time

+ TokenUsage TokenUsage

+ ToolCalls []api.ToolCall

+ ToolResults []api.Message

+ UserInput string

+ type UI interface

+ IsInteractive func() bool

+ ShowDropdown func(ctx context.Context, items interface{}, options DropdownOptions) (interface{}, error)

+ ShowQuickPrompt func(ctx context.Context, prompt string, options []QuickOption, horizontal bool) (QuickOption, error)

+ type WorkspaceFileMetadata struct

+ BrowserSeq int64

+ ContainerSeq int64

+ LastSyncedBrowser int64

+ LastSyncedContainer int64

+ ModifiedAt time.Time

+ func (m WorkspaceFileMetadata) HasUnsyncedBrowserEdits() bool

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