Struct McpClient 

pub struct McpClient {
    pub providers: HashMap<String, Arc<McpProvider>>,
    /* private fields */
}

High-level MCP client that manages multiple providers

Fields

providers: HashMap<String, Arc<McpProvider>>

Implementations

impl McpClient

pub fn new(config: McpClientConfig) -> Self

Create a new MCP client with the given configuration

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

Retrieve provider reference for a known tool name

pub fn update_allowlist(&self, allowlist: McpAllowListConfig)

Replace the in-memory MCP allow list with the provided configuration

pub fn current_allowlist(&self) -> McpAllowListConfig

Get a clone of the current allow list

pub async fn initialize(&mut self) -> Result<()>

Initialize the MCP client and connect to configured providers

pub async fn cleanup_dead_providers(&self) -> Result<()>

Clean up providers with terminated processes

pub async fn list_tools(&self) -> Result<Vec<McpToolInfo>>

List all available MCP tools across all providers

pub async fn execute_tool(&self, tool_name: &str, args: Value) -> Result<Value>

Execute a tool call on the appropriate MCP provider

pub async fn shutdown(&self) -> Result<()>

Shutdown all MCP connections

impl McpClient

pub fn get_status(&self) -> McpClientStatus

Get MCP client status information

Trait Implementations

impl McpToolExecutor for McpClient

fn execute_mcp_tool<'life0, 'life1, 'async_trait>( &'life0 self, tool_name: &'life1 str, args: Value, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute an MCP tool

fn list_mcp_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<McpToolInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List available MCP tools

fn has_mcp_tool<'life0, 'life1, 'async_trait>( &'life0 self, tool_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if an MCP tool exists

fn get_status(&self) -> McpClientStatus

Get MCP client status information