Struct McpClient 

pub struct McpClient<T: ClientTransport> { /* private fields */ }

MCP Client for connecting to MCP servers

Provides a high-level API for interacting with MCP servers, handling request/response correlation and protocol details.

Implementations

impl<T: ClientTransport + 'static> McpClient<T>

pub fn new(transport: T) -> Self

Create a new MCP client with the given transport

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

Set the default request timeout

pub fn with_client_info(self, name: &str, version: &str) -> Self

Set the client info for initialization

pub fn server_info(&self) -> Option<&InitializeResult>

Get the server info (available after initialization)

pub fn is_initialized(&self) -> bool

Check if the client has been initialized

pub async fn initialize( &mut self, client_name: &str, client_version: &str, ) -> ClientResult<InitializeResult>

Initialize the connection with the server

This must be called before any other methods.

pub async fn list_tools(&self) -> ClientResult<ListToolsResult>

List available tools from the server

pub async fn list_all_tools(&self) -> ClientResult<Vec<Tool>>

List all tools, automatically handling pagination

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

Call a tool on the server

pub async fn list_resources(&self) -> ClientResult<ListResourcesResult>

List available resources from the server

pub async fn list_all_resources(&self) -> ClientResult<Vec<Resource>>

List all resources, automatically handling pagination

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

Read a resource from the server

pub async fn list_resource_templates( &self, ) -> ClientResult<ListResourceTemplatesResult>

List resource templates from the server

pub async fn list_prompts(&self) -> ClientResult<ListPromptsResult>

List available prompts from the server

pub async fn list_all_prompts(&self) -> ClientResult<Vec<Prompt>>

List all prompts, automatically handling pagination

pub async fn get_prompt( &self, name: &str, arguments: Option<HashMap<String, String>>, ) -> ClientResult<GetPromptResult>

Get a prompt by name

pub async fn complete( &self, params: CompleteRequestParam, ) -> ClientResult<CompleteResult>

Request completion suggestions

pub async fn ping(&self) -> ClientResult<()>

Send a ping to the server

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

Close the client connection

pub async fn notify_progress( &self, progress_token: &str, progress: f64, total: Option<f64>, ) -> ClientResult<()>

Send a progress notification

pub async fn notify_cancelled( &self, request_id: &str, reason: Option<&str>, ) -> ClientResult<()>

Send a cancellation notification

pub async fn notify_roots_list_changed(&self) -> ClientResult<()>

Send a roots list changed notification