Struct InProcessMcpTransport 

pub struct InProcessMcpTransport { /* private fields */ }

In-process MCP server that dispatches calls to registered Tool objects.

Implementations

impl InProcessMcpTransport

pub fn new(name: impl Into<String>) -> Self

Create a new in-process transport, registering all provided tools.

pub async fn register<T: Tool + Send + Sync + 'static>(&mut self, tool: Arc<T>)

Register a tool with this in-process server.

Trait Implementations

impl Debug for InProcessMcpTransport

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

Formats the value using the given formatter.

impl McpTransport for InProcessMcpTransport

fn connect(&self) -> BoxFuture<'_, Result<(), AgentError>>

Establish (or re-establish) a connection to the server.

fn reconnect(&self) -> BoxFuture<'_, Result<(), AgentError>>

Reconnect after a connection drop.

fn status(&self) -> BoxFuture<'_, McpServerStatus>

Return the current connection status.

fn list_tools( &self, ) -> BoxFuture<'_, Result<Vec<McpToolDescriptor>, AgentError>>

List all tools advertised by the server.

fn call_tool( &self, tool_name: &str, arguments: Value, ) -> BoxFuture<'_, Result<Value, AgentError>>

Invoke a tool by name with the given arguments.

fn disconnect(&self) -> BoxFuture<'_, Result<(), AgentError>>

Disconnect from the server cleanly.