Struct McpClient 

pub struct McpClient { /* private fields */ }

Implementations

impl McpClient

pub async fn connect( server_url: &str, headers: Option<HashMap<String, String>>, ) -> Result<Self, McpError>

Connects to an MCP server over streamable HTTP.

Errors

Returns an error if URL resolution, HTTP client or header construction, the initialization timeout, or the MCP handshake fails.

pub async fn connect_stdio( command: &str, args: &[String], env: Option<&HashMap<String, String>>, cwd: Option<&str>, ) -> Result<Self, McpError>

Spawns a local stdio MCP server and connects over stdin/stdout.

Errors

Returns McpError::SpawnStdio if the process cannot be spawned. Returns McpError::Connect if the MCP initialization handshake fails.

pub async fn list_tools(&self) -> Result<Vec<Tool>, McpError>

Lists tools exposed by the connected MCP server.

Errors

Returns McpError::Timeout if tools/list exceeds the configured timeout. Returns McpError::Operation if the server rejects or fails the request.

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

Calls a tool exposed by the connected MCP server.

Errors

Returns McpError::InvalidArguments if arguments is not a JSON object. Returns McpError::Timeout if tools/call exceeds the configured timeout. Returns McpError::Operation if the server rejects or fails the request. Returns McpError::UnexpectedResponse if the server returns another response kind.