Struct RmcpClient 

pub struct RmcpClient { /* private fields */ }

MCP client implemented on top of the official rmcp SDK. https://github.com/modelcontextprotocol/rust-sdk

Implementations

impl RmcpClient

pub async fn new_in_process_client( factory: Arc<dyn InProcessTransportFactory>, ) -> Result<Self>

pub async fn new_stdio_client( program: OsString, args: Vec<OsString>, env: Option<HashMap<OsString, OsString>>, env_vars: &[McpServerEnvVar], cwd: Option<String>, launcher: Arc<dyn StdioServerLauncher>, ) -> Result<Self>

pub async fn new_streamable_http_client( server_name: &str, url: &str, bearer_token: Option<String>, http_headers: Option<HashMap<String, String>>, env_http_headers: Option<HashMap<String, String>>, store_mode: OAuthCredentialsStoreMode, keyring_backend_kind: AuthKeyringBackendKind, http_client: Arc<dyn HttpClient>, auth_provider: Option<SharedAuthProvider>, ) -> Result<Self>

pub async fn initialize( &self, params: InitializeRequestParams, timeout: Option<Duration>, send_elicitation: SendElicitation, ) -> Result<InitializeResult>

Perform the initialization handshake with the MCP server. https://modelcontextprotocol.io/specification/2025-06-18/basic/lifecycle#initialization

pub async fn list_tools( &self, params: Option<PaginatedRequestParams>, timeout: Option<Duration>, ) -> Result<ListToolsResult>

pub async fn list_tools_with_connector_ids( &self, params: Option<PaginatedRequestParams>, timeout: Option<Duration>, ) -> Result<ListToolsWithConnectorIdResult>

pub async fn list_resources( &self, params: Option<PaginatedRequestParams>, timeout: Option<Duration>, ) -> Result<ListResourcesResult>

pub async fn list_resource_templates( &self, params: Option<PaginatedRequestParams>, timeout: Option<Duration>, ) -> Result<ListResourceTemplatesResult>

pub async fn read_resource( &self, params: ReadResourceRequestParams, timeout: Option<Duration>, ) -> Result<ReadResourceResult>

pub async fn call_tool( &self, name: String, arguments: Option<Value>, meta: Option<Value>, timeout: Option<Duration>, ) -> Result<CallToolResult>

pub async fn send_custom_notification( &self, method: &str, params: Option<Value>, ) -> Result<()>

pub async fn send_custom_request( &self, method: &str, params: Option<Value>, ) -> Result<ServerResult>

pub async fn shutdown(&self)

Stop the MCP transport and any stdio server process owned by this client.