Struct HubConnections 

pub struct HubConnections { /* private fields */ }

Managed hub connections with shared infrastructure.

Implementations

impl HubConnections

pub fn new() -> Self

Create a new connection manager.

pub async fn connect( &self, config: McpServerConnectionConfig, ) -> Result<Arc<ManagedConnection>, McpTransportError>

Establish a connection to a server.

pub async fn establish_connection( &self, conn: &ManagedConnection, ) -> Result<(), McpTransportError>

Establish or re-establish a connection.

pub fn get(&self, server_name: &str) -> Option<Arc<ManagedConnection>>

Get a connection by server name.

pub fn remove(&self, server_name: &str) -> Option<Arc<ManagedConnection>>

Remove a connection.

pub fn server_for_tool(&self, tool_name: &str) -> Option<String>

Get server name for a tool.

pub fn get_tool_definition(&self, tool_name: &str) -> Option<McpToolDefinition>

Get tool definition by name.

pub fn list_servers(&self) -> Vec<String>

List all server names.

pub fn list_tools(&self) -> Vec<(String, McpToolDefinition)>

List all tools with their server names.

pub fn list_tool_definitions(&self) -> Vec<McpToolDefinition>

List all tool definitions.

pub fn is_connected(&self, server_name: &str) -> bool

Check if a server is connected.

pub fn clear_tools_for_server(&self, server_name: &str)

Clear tool cache for a server.

pub fn clear(&self)

Clear all connections and tool cache.

pub fn iter( &self, ) -> impl Iterator<Item = (String, Arc<ManagedConnection>)> + '_

Iterate over all connections.

pub async fn call_tool( &self, name: &str, args: Value, ) -> Result<Value, McpTransportError>

Call a tool with circuit breaker and failure handling.

pub async fn discover_tools_parallel( &self, timeout: Duration, ) -> Result<Vec<(String, McpToolDefinition)>, McpTransportError>

Discover tools from all servers in parallel.

This is much faster than sequential discovery when connecting to many servers.

pub async fn refresh_tools_parallel( &self, timeout: Duration, ) -> Result<(), McpTransportError>

Refresh tool cache from all servers in parallel.

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

Get health status of all servers.

pub fn circuit_breaker_stats( &self, server_name: &str, ) -> Option<CircuitBreakerStats>

Get circuit breaker statistics for a server.

pub fn reset_circuit_breaker(&self, server_name: &str)

Reset circuit breaker for a server.

Trait Implementations

impl Default for HubConnections

fn default() -> Self

Returns the “default value” for a type.