Struct McpConnectionManager 

pub struct McpConnectionManager { /* private fields */ }

Manages MCP connections with lifecycle, health checks, and CapabilityRegistry bridging.

McpConnectionManager owns the shared Arc<RwLock<LiveMcpConnection>> handles. The same Arc is handed to McpCapability instances so that tool calls go to the correct underlying server without locking the manager itself.

Cancellation is provided through a tokio::sync::watch channel; call McpConnectionManager::cancel to signal the health-check loop to stop.

Implementations

impl McpConnectionManager

pub fn new() -> Self

Create a new manager with its own cancellation signal.

pub fn is_cancelled(&self) -> bool

Returns true if cancel has been called.

pub fn cancel(&self)

Signal the health-check loop (and any other watchers) to stop.

pub fn subscribe_cancel(&self) -> Receiver<bool>

Returns a new watch::Receiver that fires when the manager is cancelled.

Useful for spawning the health-check loop on a separate task:

let mut cancel = manager.subscribe_cancel();
tokio::spawn(async move {
    manager.health_check_loop(registry, interval, cancel).await;
});

pub async fn connect_server( &self, config: &McpServerConfig, registry: &CapabilityRegistry, ) -> Result<usize, McpClientError>

Connect to a server and register its tools with the CapabilityRegistry.

Returns the number of tools that were registered.

pub async fn disconnect_server(&self, name: &str, registry: &CapabilityRegistry)

Disconnect a server and unregister all its tools from the registry.

pub async fn connect_all( &self, configs: &[McpServerConfig], registry: &CapabilityRegistry, )

Connect to all enabled servers in configs, logging warnings for failures.

pub async fn server_statuses(&self) -> Vec<McpServerStatus>

Status snapshot of all managed servers.

pub async fn connected_count(&self) -> usize

Number of servers whose transport channel is still alive.

pub async fn total_count(&self) -> usize

Total number of registered servers (alive or not).

pub async fn get_connection( &self, name: &str, ) -> Option<Arc<RwLock<LiveMcpConnection>>>

Get the shared connection arc for a server, for direct tool dispatch.

pub async fn health_check_loop( &self, registry: &CapabilityRegistry, interval: Duration, cancel_rx: Receiver<bool>, )

Periodically pings all connections and reconnects any that have dropped.

This method runs until cancel is called (or the provided cancel_rx fires). Intended to be spawned as a background task:

let cancel = manager.subscribe_cancel();
tokio::spawn(async move {
    manager.health_check_loop(registry, Duration::from_secs(30), cancel).await;
});

Trait Implementations

impl Default for McpConnectionManager

fn default() -> Self

Returns the “default value” for a type.