Struct McpConnectionPool 

pub struct McpConnectionPool { /* private fields */ }

MCP connection pool for efficient provider management

Implementations

impl McpConnectionPool

pub fn new( max_concurrent_connections: usize, connection_timeout_seconds: u64, ) -> Self

pub async fn initialize_providers_parallel( &self, provider_configs: Vec<McpProviderConfig>, elicitation_handler: Option<Arc<dyn McpElicitationHandler>>, tool_timeout: Option<Duration>, allowlist_snapshot: &McpAllowListConfig, ) -> Result<Vec<(String, Arc<McpProvider>)>, McpPoolError>

Initialize multiple providers in parallel with controlled concurrency

pub async fn get_provider(&self, name: &str) -> Option<Arc<McpProvider>>

Get a provider by name

pub async fn get_all_providers(&self) -> Vec<Arc<McpProvider>>

Get all active providers

pub async fn remove_provider(&self, name: &str) -> Option<Arc<McpProvider>>

Remove a provider from the pool

pub async fn has_provider(&self, name: &str) -> bool

Check if a provider exists in the pool

pub async fn stats(&self) -> ConnectionPoolStats

Get connection pool statistics

pub async fn shutdown_all(&self)

Shutdown all providers gracefully

pub async fn health_check(&self) -> HashMap<String, bool>

Check the health of all active providers.

Returns a map of provider name → true (healthy) / false (unhealthy).

pub async fn reconnect_unhealthy( &self, startup_timeout: Option<Duration>, tool_timeout: Option<Duration>, allowlist: &McpAllowListConfig, ) -> Vec<String>

Attempt to reconnect any unhealthy providers.

Returns the names of providers that were successfully reconnected.