server

Apr 1, 2026

Changes in this version

type Server

+ func (s *Server) GetToolApprovalStatus(serverName, toolName string) (string, error)

+ func (s *Server) UpdateServer(ctx context.Context, serverName string, updates *config.ServerConfig) error

Mar 23, 2026

Changes in this version

+ type SessionRisk struct

+ HasDestructive bool

+ HasOpenWorld bool

+ HasWrite bool

+ LethalTrifecta bool

+ Level string

+ Warning string

Mar 23, 2026

Changes in this version

type SessionStore

+ func (s *SessionStore) UpdateActivity(sessionID string)

Mar 11, 2026

Changes in this version

+ const DirectModeToolSeparator

+ func FormatDirectToolName(serverName, toolName string) string

+ func ParseDirectToolName(directName string) (serverName, toolName string, ok bool)

+ func SetMCPServerVersion(v string)

type MCPProxyServer

+ func (p *MCPProxyServer) GetCallToolServer() *mcpserver.MCPServer

+ func (p *MCPProxyServer) GetCodeExecServer() *mcpserver.MCPServer

+ func (p *MCPProxyServer) GetDirectServer() *mcpserver.MCPServer

+ func (p *MCPProxyServer) GetMCPServerForMode(mode string) *mcpserver.MCPServer

+ func (p *MCPProxyServer) RefreshCodeExecModeTools()

+ func (p *MCPProxyServer) RefreshDirectModeTools()

type Server

+ func (s *Server) ApproveAllTools(serverName string, approvedBy string) (int, error)

+ func (s *Server) ApproveTools(serverName string, toolNames []string, approvedBy string) error

+ func (s *Server) GetToolApproval(serverName, toolName string) (*storage.ToolApprovalRecord, error)

+ func (s *Server) ListToolApprovals(serverName string) ([]*storage.ToolApprovalRecord, error)

Jan 14, 2026

Changes in this version

+ const ConnectionSourceTCP

+ const ConnectionSourceTray

+ func TagConnectionContext(ctx context.Context, source ConnectionSource) context.Context

+ func ValidateDataDirectory(dataDir string, logger *zap.Logger) error

+ type ConnectionSource = transport.ConnectionSource

+ func GetConnectionSource(ctx context.Context) ConnectionSource

+ type IsolationChecker interface

+ DetectRuntimeType func(command string) string

+ GetDockerImage func(serverConfig *config.ServerConfig, runtimeType string) (string, error)

+ GetDockerIsolationWarning func(serverConfig *config.ServerConfig) string

+ ShouldIsolate func(serverConfig *config.ServerConfig) bool

+ type Listener struct

+ Address string

+ Source ConnectionSource

+ type ListenerConfig struct

+ DataDir string

+ Logger *zap.Logger

+ TCPAddress string

+ TrayEndpoint string

+ type ListenerManager struct

+ func NewListenerManager(config *ListenerConfig) *ListenerManager

+ func (m *ListenerManager) CloseAll() error

+ func (m *ListenerManager) CreateTCPListener() (*Listener, error)

+ func (m *ListenerManager) CreateTrayListener() (*Listener, error)

+ func (m *ListenerManager) GetListeners() []*Listener

+ type MCPProxyServer struct

+ func NewMCPProxyServer(storage *storage.Manager, index *index.Manager, ...) *MCPProxyServer

+ func (p *MCPProxyServer) CallBuiltInTool(ctx context.Context, toolName string, arguments map[string]interface{}) (*mcp.CallToolResult, error)

+ func (p *MCPProxyServer) CallToolDirect(ctx context.Context, request mcp.CallToolRequest) (interface{}, error)

+ func (p *MCPProxyServer) Close() error

+ func (p *MCPProxyServer) GetMCPServer() *mcpserver.MCPServer

+ type PermissionError struct

+ Err error

+ Path string

+ func (e *PermissionError) Error() string

+ func (e *PermissionError) Unwrap() error

+ type PortInUseError struct

+ Address string

+ Err error

+ func (e *PortInUseError) Error() string

+ func (e *PortInUseError) Unwrap() error

+ type Server struct

+ func NewServer(cfg *config.Config, logger *zap.Logger) (*Server, error)

+ func NewServerWithConfigPath(cfg *config.Config, configPath string, logger *zap.Logger) (*Server, error)

+ func (s *Server) AddServer(ctx context.Context, serverConfig *config.ServerConfig) error

+ func (s *Server) ApplyConfig(cfg *config.Config, cfgPath string) (*runtime.ConfigApplyResult, error)

+ func (s *Server) CallTool(ctx context.Context, toolName string, arguments map[string]interface{}) (interface{}, error)

+ func (s *Server) DiscoverServerTools(ctx context.Context, serverName string) error

+ func (s *Server) EnableServer(serverName string, enabled bool) error

+ func (s *Server) EventsChannel() <-chan runtime.Event

+ func (s *Server) ForceReconnectAllServers(reason string) error

+ func (s *Server) GetActivity(id string) (*storage.ActivityRecord, error)

+ func (s *Server) GetAllServers() ([]map[string]interface{}, error)

+ func (s *Server) GetConfig() (*config.Config, error)

+ func (s *Server) GetConfigPath() string

+ func (s *Server) GetCurrentConfig() interface{}

+ func (s *Server) GetDockerRecoveryStatus() *storage.DockerRecoveryState

+ func (s *Server) GetListenAddress() string

+ func (s *Server) GetLogDir() string

+ func (s *Server) GetManagementService() interface{}

+ func (s *Server) GetQuarantinedServers() ([]map[string]interface{}, error)

+ func (s *Server) GetRecentSessions(limit int) ([]*contracts.MCPSession, int, error)

+ func (s *Server) GetSecretResolver() *secret.Resolver

+ func (s *Server) GetServerLogs(serverName string, tail int) ([]contracts.LogEntry, error)

+ func (s *Server) GetServerToolCalls(serverName string, limit int) ([]*contracts.ToolCallRecord, error)

+ func (s *Server) GetServerTools(serverName string) ([]map[string]interface{}, error)

+ func (s *Server) GetSessionByID(sessionID string) (*contracts.MCPSession, error)

+ func (s *Server) GetStatus() interface{}

+ func (s *Server) GetTokenSavings() (*contracts.ServerTokenMetrics, error)

+ func (s *Server) GetToolCallByID(id string) (*contracts.ToolCallRecord, error)

+ func (s *Server) GetToolCalls(limit, offset int) ([]*contracts.ToolCallRecord, int, error)

+ func (s *Server) GetToolCallsBySession(sessionID string, limit, offset int) ([]*contracts.ToolCallRecord, int, error)

+ func (s *Server) GetUpstreamStats() map[string]interface{}

+ func (s *Server) GetVersionInfo() *updatecheck.VersionInfo

+ func (s *Server) IsReady() bool

+ func (s *Server) IsRunning() bool

+ func (s *Server) ListActivities(filter storage.ActivityFilter) ([]*storage.ActivityRecord, int, error)

+ func (s *Server) ListRegistries() ([]interface{}, error)

+ func (s *Server) NotifySecretsChanged(ctx context.Context, operation, secretName string) error

+ func (s *Server) OnUpstreamServerChange()

+ func (s *Server) QuarantineServer(serverName string, quarantined bool) error

+ func (s *Server) RefreshVersionInfo() *updatecheck.VersionInfo

+ func (s *Server) ReloadConfiguration() error

+ func (s *Server) RemoveServer(ctx context.Context, serverName string) error

+ func (s *Server) ReplayToolCall(id string, arguments map[string]interface{}) (*contracts.ToolCallRecord, error)

+ func (s *Server) RestartServer(serverName string) error

+ func (s *Server) SaveConfiguration() error

+ func (s *Server) SearchRegistryServers(registryID, tag, query string, limit int) ([]interface{}, error)

+ func (s *Server) SearchTools(query string, limit int) ([]map[string]interface{}, error)

+ func (s *Server) SetListenAddress(addr string, persist bool) error

+ func (s *Server) SetShutdownInfo(reason, signal string)

+ func (s *Server) Shutdown() error

+ func (s *Server) Start(ctx context.Context) error

+ func (s *Server) StartServer(ctx context.Context) error

+ func (s *Server) StatusChannel() <-chan interface{}

+ func (s *Server) StopServer() error

+ func (s *Server) StreamActivities(filter storage.ActivityFilter) <-chan *storage.ActivityRecord

+ func (s *Server) SubscribeEvents() chan runtime.Event

+ func (s *Server) SuggestAlternateListen(baseAddr string) (string, error)

+ func (s *Server) TriggerOAuthLogin(serverName string) error

+ func (s *Server) UnquarantineServer(serverName string) error

+ func (s *Server) UnsubscribeEvents(ch chan runtime.Event)

+ func (s *Server) ValidateConfig(cfg *config.Config) ([]config.ValidationError, error)

+ type SessionInfo struct

+ ClientName string

+ ClientVersion string

+ SessionID string

+ type SessionStore struct

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

+ func (s *SessionStore) Count() int

+ func (s *SessionStore) GetSession(sessionID string) *SessionInfo

+ func (s *SessionStore) RemoveSession(sessionID string)

+ func (s *SessionStore) SetSession(sessionID, clientName, clientVersion string, hasRoots, hasSampling bool, ...)

+ func (s *SessionStore) SetStorageManager(manager *storage.Manager)

+ func (s *SessionStore) UpdateSessionStats(sessionID string, tokens int)

+ type Status struct

+ LastUpdated time.Time

+ Message string

+ Phase string

+ ToolsIndexed int

+ UpstreamStats map[string]interface{}

+ type Ucred struct — darwin/amd64, linux/amd64

+ Gid uint32

+ Pid int32

+ Uid uint32