agent

May 6, 2026

Changes in this version

+ func SetupSystemWorkspace(agentID, basePath string) (string, error)

+ type BusyTracker interface

+ Busy func() bool

type GoRunner

+ func (r *GoRunner) Busy() bool

type GoRunnerConfig

+ SubagentTimeout time.Duration

May 5, 2026

Changes in this version

+ func EnsureAnnaCLIInPath(annaHome string) error

type GoRunnerConfig

+ TokenService *auth.TokenService

type PoolManager

+ func (pm *PoolManager) SetTokenService(ctx context.Context, ts *auth.TokenService)

type PoolManagerOption

+ func WithTokenService(ts *auth.TokenService) PoolManagerOption

Apr 29, 2026

Changes in this version

type DBPromptParams

+ KnowledgeStore pkgplugins.KnowledgeStore

+ PluginPrompts []pkgplugins.SystemPromptSection

+ SnapshotUpdatedAt time.Time

+ SnapshotVersion int64

type GoRunnerConfig

+ PluginPrompts []pkgplugins.SystemPromptSection

+ type PluginPromptsBuilder func() []pkgplugins.SystemPromptSection

type PoolManagerOption

+ func WithPluginPromptsBuilder(b PluginPromptsBuilder) PoolManagerOption

type PoolOption

+ func WithSnapshotPromptBuilder(...) PoolOption

Apr 28, 2026

Changes in this version

+ func BuildSystemPromptFromDB(ctx context.Context, p DBPromptParams) string

+ func ChannelFromContext(ctx context.Context) (string, bool)

+ func DecodeEvent(raw []byte) (ai.AssistantEvent, error)

+ func DefaultAgentSoul() string

+ func DefaultSystemPrompt() string

+ func EncodeEvent(event ai.AssistantEvent) ([]byte, error)

+ func ExcludedToolsFromContext(ctx context.Context) []string

+ func MessageText(message MessageContent) string

+ func SaveAsset(assetsDir, fileName string, data []byte) (string, error)

+ func SystemOverrideFromContext(ctx context.Context) (string, bool)

+ func UserAssetsDir(userRoot string) string

+ func WithChannel(ctx context.Context, channel string) context.Context

+ func WithExcludedTools(ctx context.Context, names ...string) context.Context

+ func WithSystemOverride(ctx context.Context, system string) context.Context

+ type ActivityTracker interface

+ LastActivity func() time.Time

+ type Aliver interface

+ Alive func() bool

+ type DBPromptParams struct

+ AgentID string

+ AgentRoot string

+ AgentSoul string

+ AnnaHome string

+ Host sandbox.Host

+ Memory memory.Provider

+ ProjectRoot string

+ PromptSections []pkgplugins.SystemPromptSection

+ PromptTools []pkgplugins.PromptToolInfo

+ SystemPrompt string

+ UserID int64

+ UserRoot string

+ type Envelope struct

+ Data json.RawMessage

+ Type string

+ type Event struct

+ Err error

+ File *FileEvent

+ Image *ImageEvent

+ Store ai.Message

+ Text string

+ ToolUse *ToolUseEvent

+ type FileEvent struct

+ Name string

+ Path string

+ type GoRunner struct

+ func NewGoRunner(ctx context.Context, cfg GoRunnerConfig) (*GoRunner, error)

+ func (r *GoRunner) Alive() bool

+ func (r *GoRunner) Chat(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event

+ func (r *GoRunner) Close() error

+ func (r *GoRunner) LastActivity() time.Time

+ func (r *GoRunner) SystemPrompt() string

+ type GoRunnerConfig struct

+ API string

+ APIKey string

+ AgentRoot string

+ AnnaHome string

+ BaseURL string

+ ExtraTools []tools.Tool

+ HookPlugins []hooks.HookPlugin

+ Model string

+ PluginTools func(context.Context, plugintools.BuildContext) []tools.Tool

+ ProjectRoot string

+ PromptSections []pkgplugins.SystemPromptSection

+ Providers ProviderRegistryBuilder

+ Sandbox config.SandboxConfig

+ SandboxBackendFn func(ctx context.Context) string

+ SessionEnvSpecs []pkgplugins.SessionEnvSpec

+ System string

+ TokenManager *oauth.TokenManager

+ ToolLifecycle *coreagent.ToolLifecycle

+ UserID int64

+ UserRoot string

+ VaultEnvLoader VaultEnvLoader

+ type HandlerFunc func(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event

+ func (f HandlerFunc) Chat(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event

+ type ImageEvent struct

+ Data string

+ MimeType string

+ type MessageContent = any

+ type NewRunnerFunc func(ctx context.Context, params RunnerParams) (Runner, error)

+ type Runner interface

+ Chat func(ctx context.Context, history []ai.Message, message MessageContent) <-chan Event

+ type RunnerParams struct

+ AgentID string

+ HooksFn func() []hooks.HookPlugin

+ Memory any

+ Model string

+ UserID int64

+ type Stateful interface

+ Stateful func() bool

+ type SystemPrompter interface

+ SystemPrompt func() string

+ type ToolUseEvent struct

+ Detail string

+ Input string

+ Status string

+ Tool string

+ type VaultEnvLoader interface

+ LoadEnv func(ctx context.Context, userID int64) (map[string]string, error)

Apr 24, 2026

Changes in this version

type PoolManager

+ func (pm *PoolManager) SetOAuthRegistry(r *oauth.ProviderRegistry)

type PoolManagerOption

+ func WithSessionPluginViewBuilder(b SessionPluginViewBuilder) PoolManagerOption

+ type SessionPluginViewBuilder func(ctx context.Context) (pkgplugins.SessionPluginView, error)

Apr 22, 2026

Changes in this version

type Pool

+ func (p *Pool) ResetRunnersForUser(userID int64) error

type PoolManager

+ func (pm *PoolManager) AddBuiltinTool(ctx context.Context, tool tools.Tool) error

+ func (pm *PoolManager) InvalidateUser(userID int64) error

+ func (pm *PoolManager) SetVaultEnvLoader(ctx context.Context, v runner.VaultEnvLoader)

type PoolManagerOption

+ func WithTokenManager(tm *oauth.TokenManager) PoolManagerOption

+ func WithVaultEnvLoader(v runner.VaultEnvLoader) PoolManagerOption

Apr 20, 2026

Changes in this version

type PoolManagerOption

+ func WithSkillStore(s pkgplugins.SkillStore) PoolManagerOption

Apr 15, 2026

Changes in this version

+ type BuiltinToolsFactory func(snap *config.Snapshot) []tools.Tool

type PoolManagerOption

+ func WithBuiltinTools(tools []tools.Tool) PoolManagerOption

+ func WithBuiltinToolsFactory(f BuiltinToolsFactory) PoolManagerOption

Apr 14, 2026

Changes in this version

+ func UserRoot(userWorkspace string) string

Apr 14, 2026

Changes in this version

type Pool

+ func (p *Pool) ResetRunners() error

+ func (p *Pool) SetFastModel(model string)

type PoolManager

+ func (pm *PoolManager) SyncAgent(ctx context.Context, agentID string) error

Apr 10, 2026

Changes in this version

+ func BuildUserSessionKey(agentID string, authUserID int64, channelContext string) string

+ func SetupUserWorkspace(agentID, basePath string, userID int64) (string, error)

+ func UserDataDir(userWorkspace string) string

+ func UserSkillsDir(userWorkspace string) string

+ type BeforeRunBuilder func(ctx context.Context, build pkgplugins.BeforeRunContext) (pkgplugins.BeforeRunResult, error)

+ type CoreToolsBuilder = runner.CoreToolsBuilder

+ type PluginHooksBuilder func(ctx context.Context) []hooks.HookPlugin

+ type PluginToolsBuilder func(ctx context.Context) []tools.Tool

type Pool

+ func (p *Pool) SetHooks(fn func() []hooks.HookPlugin)

type PoolManager

+ func (pm *PoolManager) HookPlugins() []hooks.HookPlugin

+ func (pm *PoolManager) ReloadPluginHooks(ctx context.Context) error

+ func (pm *PoolManager) ReloadPluginProviders(ctx context.Context) error

+ func (pm *PoolManager) ReloadPluginTools(ctx context.Context) error

type PoolManagerOption

+ func WithBeforeRunBuilderPM(b BeforeRunBuilder) PoolManagerOption

+ func WithCoreToolsBuilder(b CoreToolsBuilder) PoolManagerOption

+ func WithPluginHooksBuilder(b PluginHooksBuilder) PoolManagerOption

+ func WithPluginToolsBuilder(b PluginToolsBuilder) PoolManagerOption

+ func WithPromptSectionsBuilder(b PromptSectionsBuilder) PoolManagerOption

+ func WithPromptToolsBuilder(b PromptToolsBuilder) PoolManagerOption

+ func WithProviderRegistryBuilder(b ProviderRegistryBuilder) PoolManagerOption

+ func WithToolLifecyclePM(tl *coreagent.ToolLifecycle) PoolManagerOption

type PoolOption

+ func WithBeforeRunBuilder(b BeforeRunBuilder) PoolOption

+ type PromptSectionsBuilder func(ctx context.Context, build pkgplugins.SystemPromptContext) ([]pkgplugins.SystemPromptSection, error)

+ type PromptToolsBuilder func(ctx context.Context) ([]pkgplugins.PromptToolInfo, error)

+ type ProviderRegistryBuilder func(api, apiKey, baseURL string) (*providers.Registry, error)

Mar 17, 2026

Changes in this version

+ func BuildSessionKey(agentID, platform, externalUserID, channelContext string) string

+ func NewRunnerFactory(snap *config.Snapshot, extraTools []agenttool.Tool, ...) (runner.NewRunnerFunc, error)

+ func SetupWorkspace(agentID, basePath string) (string, error)

+ type ExtraToolsFactory func(snap *config.Snapshot) []agenttool.Tool

type Pool

+ func (p *Pool) AgentID() string

+ type PoolManager struct

+ func NewPoolManager(store config.Store, mem memory.Engine, opts ...PoolManagerOption) *PoolManager

+ func (pm *PoolManager) Close() error

+ func (pm *PoolManager) DefaultPool() *Pool

+ func (pm *PoolManager) Get(agentID string) *Pool

+ func (pm *PoolManager) StartAll(ctx context.Context) error

+ type PoolManagerOption func(*PoolManager)

+ func WithCompactionPM(cfg CompactionConfig) PoolManagerOption

+ func WithExtraToolsFactory(f ExtraToolsFactory) PoolManagerOption

+ func WithIdleTimeoutPM(d time.Duration) PoolManagerOption

+ func WithPluginHooksPM(hooks engine.PluginHookRunner) PoolManagerOption

+ func WithSharedExtraTools(tools []agenttool.Tool) PoolManagerOption

type PoolOption

+ func WithAgentID(id string) PoolOption

+ func WithUserMemory(store *memory.UserMemoryStore) PoolOption

Mar 16, 2026

Changes in this version

type PoolOption

+ func WithPluginHooks(hooks engine.PluginHookRunner) PoolOption

Mar 13, 2026

Changes in this version

+ type ChatOption func(*chatOptions)

+ func WithModel(model string) ChatOption

+ type CompactionConfig struct

+ KeepTail int

+ MaxTokens int

+ func (c CompactionConfig) WithDefaults() CompactionConfig

+ type Pool struct

+ func NewPool(factory runner.NewRunnerFunc, mem memory.Engine, opts ...PoolOption) *Pool

+ func (p *Pool) ActiveSession(channel string) (SessionInfo, bool)

+ func (p *Pool) ArchiveSession(sessionID string) error

+ func (p *Pool) Chat(ctx context.Context, sessionID string, message runner.MessageContent, ...) <-chan runner.Event

+ func (p *Pool) Close() error

+ func (p *Pool) CompactSession(ctx context.Context, sessionID string) (string, error)

+ func (p *Pool) CreateSession(channel string) (SessionInfo, error)

+ func (p *Pool) GetSession(sessionID string) (SessionInfo, error)

+ func (p *Pool) History(sessionID string) []ai.Message

+ func (p *Pool) ListSessions(includeArchived bool) ([]SessionInfo, error)

+ func (p *Pool) NeedsCompaction(sessionID string) bool

+ func (p *Pool) ResolveSession(channel string) (SessionInfo, error)

+ func (p *Pool) RotateSession(channel string) (SessionInfo, error)

+ func (p *Pool) SetDefaultModel(model string)

+ func (p *Pool) SetFactory(factory runner.NewRunnerFunc)

+ func (p *Pool) StartReaper(ctx context.Context)

+ type PoolOption func(*Pool)

+ func WithCompaction(cfg CompactionConfig) PoolOption

+ func WithDefaultModel(model string) PoolOption

+ func WithFastModel(model string) PoolOption

+ func WithIdleTimeout(d time.Duration) PoolOption

+ type Session struct

+ Info SessionInfo

+ Model string

+ Runner runner.Runner

+ type SessionInfo = memory.SessionInfo