Struct McpClient 

pub struct McpClient { /* private fields */ }

MCP Client for connecting to external servers

Implementations

impl McpClient

pub async fn connect_subprocess( command: &str, args: &[&str], ) -> Result<Arc<Self>>

Connect to an MCP server via subprocess

pub fn new(transport: Arc<dyn Transport>) -> Self

Create a new MCP client with custom transport

pub fn with_registry( transport: Arc<dyn Transport>, registry: Arc<McpRegistry>, name: Option<String>, ) -> Self

Create a new MCP client with a shared registry for multi-server management

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

Initialize the connection with the server

pub fn registry(&self) -> Arc<McpRegistry>

Get the registry associated with this client

pub async fn server_name(&self) -> Option<String>

Get the server name if set

pub async fn set_server_name(&self, name: String)

Set the server name for registry tracking

pub async fn has_capability(&self, capability: &str) -> bool

Check if the connected server has a specific capability

pub async fn capabilities(&self) -> Option<ServerCapabilities>

Get server capabilities

pub async fn discover_tools_from_registry(&self) -> Vec<(String, McpTool)>

Discover tools from the registry across all connected servers

pub async fn find_tool_in_registry( &self, tool_name: &str, ) -> Option<(String, McpTool)>

Find a tool across all servers in the registry

pub async fn refresh_tools(&self) -> Result<Vec<McpTool>>

Refresh the list of available tools

pub async fn tools(&self) -> Vec<McpTool>

Get available tools

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

Call a tool

pub async fn list_resources(&self) -> Result<Vec<McpResource>>

List available resources

pub async fn read_resource(&self, uri: &str) -> Result<ReadResourceResult>

Read a resource

pub async fn list_prompts(&self) -> Result<Vec<McpPrompt>>

List available prompts

pub async fn get_prompt( &self, name: &str, arguments: Value, ) -> Result<GetPromptResult>

Get a prompt

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

Close the connection