Struct McpServerManager 

pub struct McpServerManager { /* private fields */ }

Manages the lifecycle of one or more MCP servers.

Implementations

impl McpServerManager

pub fn new() -> Self

Creates an empty server manager with no registered servers.

pub fn with_namespace(self, namespace: McpToolNamespace) -> Self

Sets the tool naming strategy for every adapter built by this manager.

pub fn set_namespace(&mut self, namespace: McpToolNamespace) -> &mut Self

Replaces the tool naming strategy in place.

pub fn namespace(&self) -> &McpToolNamespace

Returns the active tool naming strategy.

pub fn with_handler_config(self, handler_config: McpHandlerConfig) -> Self

Replaces the McpHandlerConfig applied to every connection this manager opens.

pub fn set_handler_config( &mut self, handler_config: McpHandlerConfig, ) -> &mut Self

Sets the McpHandlerConfig in place.

pub fn handler_config(&self) -> &McpHandlerConfig

Returns the active McpHandlerConfig.

pub fn with_server(self, config: McpServerConfig) -> Self

Registers a server configuration. Returns self for chaining.

pub fn with_server_options( self, config: McpServerConfig, options: McpServerOptions, ) -> Self

Registers a server configuration with lifecycle options. Returns self for chaining.

pub fn register_server(&mut self, config: McpServerConfig) -> &mut Self

Registers a server configuration by mutable reference.

pub fn register_server_with_options( &mut self, config: McpServerConfig, options: McpServerOptions, ) -> &mut Self

Registers a server configuration and lifecycle options by mutable reference.

pub fn connected_server( &self, server_id: &McpServerId, ) -> Option<&McpServerHandle>

Returns the handle for a connected server, or None if not connected.

pub fn connected_servers(&self) -> Vec<&McpServerHandle>

Returns handles for all currently connected servers.

pub fn subscribe_catalog_events(&self) -> Receiver<McpCatalogEvent>

Subscribes to MCP catalog and lifecycle events.

pub async fn connect_server( &mut self, server_id: &McpServerId, ) -> Result<McpServerHandle, McpError>

Connects a single registered server by its identifier.

pub async fn connect_all(&mut self) -> Result<Vec<McpServerHandle>, McpError>

Connects all registered servers concurrently.

pub async fn connect_all_settled(&mut self) -> McpConnectAllSettled

Connects all registered servers concurrently and waits for every connection attempt to settle.

Unlike Self::connect_all, this method does not fail fast. Every server is attempted in parallel; successful connections are installed into the manager and tool catalog, while each failed connection is returned with its McpServerId and McpError.

pub async fn refresh_server( &mut self, server_id: &McpServerId, ) -> Result<McpDiscoverySnapshot, McpError>

Re-discovers capabilities for a connected server.

pub async fn refresh_changed_catalogs( &mut self, ) -> Result<Vec<McpCatalogEvent>, McpError>

Processes pending server list-change notifications.

pub async fn disconnect_server( &mut self, server_id: &McpServerId, ) -> Result<(), McpError>

Disconnects a server and removes it from active connections.

pub async fn resolve_auth( &mut self, resolution: AuthResolution, ) -> Result<(), McpError>

Stores or clears authentication credentials for a server.

pub fn tool_registry(&self) -> ToolRegistry

Builds a one-shot snapshot ToolRegistry of every tool across all connected servers. Use source instead when wiring the manager into an [agentkit_loop::Agent] so tool catalog changes flow through automatically.

pub fn source(&self) -> CatalogReader

Returns the manager’s federated CatalogReader.

The manager keeps an internal CatalogWriter in sync with every connect, disconnect, and catalog refresh; the returned reader sees the added/removed/changed tool sets via [ToolSource::drain_catalog_events]. Pass it to [agentkit_loop::AgentBuilder::tools] alongside any frozen native ToolRegistry.

Each call returns a fresh reader subscription — events emitted before this call are not replayed. Call once at agent setup time and reuse.

pub fn capability_provider(&self) -> McpCapabilityProvider

Builds a combined McpCapabilityProvider from all connected servers.

Trait Implementations

impl Default for McpServerManager

fn default() -> Self

Returns the “default value” for a type.