mcp_protocol_sdk::transport::traits

Trait ServerTransport

Source 
pub trait ServerTransport: Send + Sync {
    // Required methods
    fn start<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn handle_request<'life0, 'async_trait>(
        &'life0 mut self,
        request: JsonRpcRequest,
    ) -> Pin<Box<dyn Future<Output = McpResult<JsonRpcResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn send_notification<'life0, 'async_trait>(
        &'life0 mut self,
        notification: JsonRpcNotification,
    ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stop<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided methods
    fn is_running(&self) -> bool { ... }
    fn server_info(&self) -> String { ... }
}
Expand description

Transport trait for MCP servers

This trait defines the interface for handling incoming requests and sending responses in a server-side MCP connection.

Required Methods§

Source

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Start the server transport and begin listening for connections

§Returns

Result indicating success or an error

Source

fn handle_request<'life0, 'async_trait>( &'life0 mut self, request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = McpResult<JsonRpcResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Handle an incoming JSON-RPC request and return a response

§Arguments
  • request - The incoming JSON-RPC request
§Returns

Result containing the JSON-RPC response or an error

Source

fn send_notification<'life0, 'async_trait>( &'life0 mut self, notification: JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Send a JSON-RPC notification to the client

§Arguments
  • notification - The JSON-RPC notification to send
§Returns

Result indicating success or an error

Source

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Stop the server transport

§Returns

Result indicating success or an error

Provided Methods§

Source

fn is_running(&self) -> bool

Check if the server is running

§Returns

True if the server is running and accepting connections

Source

fn server_info(&self) -> String

Get server information for debugging

§Returns

String describing the server state

Implementors§