Struct McpClient 

pub struct McpClient { /* private fields */ }

Manages a single MCP server process with stdio JSON-RPC communication.

I/O handles are stored persistently so that concurrent requests can be serialized through the same connection without consuming the handles.

Example

let client = McpClient::new(server_config);
client.initialize().await?;
let tools = client.list_tools().await?;
let result = client.call_tool("my_tool", serde_json::json!({"arg": "value"})).await?;
client.shutdown().await?;

Implementations

impl McpClient

pub fn new(server: McpServer) -> McpClient

Create a new MCP client for the given server configuration.

Does NOT spawn the process yet — call initialize() to start and negotiate.

pub fn with_timeout(self, timeout: Duration) -> McpClient

Set the request timeout duration.

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

Spawn the MCP server process and establish communication.

pub async fn is_initialized(&self) -> bool

Check if the server has been initialized

pub async fn server_info(&self) -> Option<ServerInfo>

Get the server info received during initialize

pub async fn list_tools(&self) -> Result<Vec<McpTool>, Error>

List all tools available from this MCP server.

Results are cached and refreshed on refresh_tools.

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

Force-refresh the tool list from the server.

pub async fn call_tool( &self, tool_name: &str, arguments: Value, ) -> Result<McpToolCallResult, Error>

Call a tool on this MCP server.

The server must be initialized first.

pub async fn call_tool_text( &self, tool_name: &str, arguments: Value, ) -> Result<String, Error>

Call a tool and return the result content as a string.

Returns the first text content block, or an error if no text content.

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

Gracefully shutdown the MCP server process.

Drops persistent I/O handles first, then kills the child process.

pub async fn restart(&self) -> Result<(), Error>

Restart the server (shutdown then initialize).

pub fn server(&self) -> &McpServer

Get the server configuration

Trait Implementations

impl Debug for McpClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.