Struct MCPClient 

pub struct MCPClient { /* private fields */ }

An MCP client that provides tools from an MCP server.

Implementations

impl MCPClient

pub fn new(config: MCPServerConfig) -> Self

Creates a new MCP client with the given configuration.

pub fn stdio( name: impl Into<String>, command: impl Into<String>, args: Vec<String>, ) -> Self

Creates an MCP client with stdio transport.

pub fn sse(name: impl Into<String>, url: impl Into<String>) -> Self

Creates an MCP client with SSE transport.

pub fn with_filters(self, filters: ToolFilters) -> Self

Sets tool filters for this client.

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

Sets a prefix for tool names.

pub fn with_timeout(self, timeout_secs: u64) -> Self

Sets the connection timeout.

pub fn name(&self) -> &str

Returns the server name.

pub async fn is_connected(&self) -> bool

Checks if the client is connected.

pub async fn connection_state(&self) -> ConnectionState

Returns the current connection state.

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

Connects to the MCP server and discovers available tools.

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

Disconnects from the MCP server.

pub async fn tools(&self) -> Vec<Arc<dyn AgentTool>>

Returns the list of available tools from the MCP server.

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

Calls a tool on the MCP server.

Trait Implementations

impl ToolProvider for MCPClient

fn load_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Arc<dyn AgentTool>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads and returns the tools in this provider.

fn add_consumer(&self, consumer_id: &str)

Adds a consumer to this tool provider.

fn remove_consumer(&self, consumer_id: &str)

Removes a consumer from this tool provider.