Struct McpHub 

pub struct McpHub { /* private fields */ }

Central hub for MCP tool routing across multiple servers.

The McpHub provides:

• Connection management for multiple MCP servers
• Tool discovery and caching
• Automatic routing of tool calls to the correct server

Example

use mcp::{McpHub, McpServerConnectionConfig};

let hub = McpHub::new();

// Connect to an external server
let config = McpServerConnectionConfig::stdio("my-server", "node", vec!["server.js".into()]);
hub.connect(config).await?;

// List all available tools
let tools = hub.list_all_tools().await?;

// Call a tool (automatically routed to correct server)
let result = hub.call_tool("my_tool", serde_json::json!({"arg": "value"})).await?;

Implementations

impl McpHub

pub fn new() -> Self

Create a new empty hub.

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

Connect to an MCP server.

This method:

1. Creates the appropriate transport based on config
2. Initializes the connection
3. Discovers tools and caches the mapping
4. Returns the transport for direct access if needed

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

Call a tool, automatically routing to the correct server.

pub async fn list_tools( &self, ) -> Result<Vec<(String, ToolDefinition)>, McpTransportError>

List all tools from all connected servers.

pub async fn list_all_tools( &self, ) -> Result<Vec<ToolDefinition>, McpTransportError>

Get all registered tools as a flat list.

pub async fn refresh_tool_cache(&self) -> Result<(), McpTransportError>

Populate the tool cache by querying all servers.

pub fn register_tool_sync(&self, tool_name: &str, server_name: &str)

Manually register a tool in the cache.

pub async fn shutdown_all(&self) -> Result<(), McpTransportError>

Shutdown all connected servers.

pub async fn disconnect( &self, server_name: &str, ) -> Result<(), McpTransportError>

Disconnect a specific server.

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

Get list of connected server names.

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

Check if a server is connected.

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

Get health status of all servers.

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

Get the server name that provides a specific tool.

Trait Implementations

impl Default for McpHub

fn default() -> Self

Returns the “default value” for a type.