Struct McpServer 

pub struct McpServer { /* private fields */ }

The core MCP server — holds configuration and the routing table.

Create one with McpServer::builder() then call .serve_stdio() or another transport extension method to start accepting connections.

Implementations

impl McpServer

pub fn builder() -> McpServerBuilder

pub async fn handle_message( &self, msg: JsonRpcMessage, session: &mut Session, ) -> Option<JsonRpcMessage>

Handle a single incoming JSON-RPC message, returning the response (if any).

pub fn info(&self) -> &ServerInfo

Trait Implementations

impl Clone for McpServer

fn clone(&self) -> McpServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ServeSseExt for McpServer

fn serve_sse( self, addr: impl Into<SocketAddr>, ) -> impl Future<Output = McpResult<()>> + Send

impl ServeStdioExt for McpServer

fn serve_stdio(self) -> impl Future<Output = McpResult<()>> + Send

impl ServeStreamableExt for McpServer

fn serve_streamable( self, addr: impl Into<SocketAddr>, ) -> impl Future<Output = McpResult<()>> + Send

Serve using the Streamable HTTP transport.

impl ServeWebSocketExt for McpServer

async fn serve_websocket( self, addr: impl Into<SocketAddr> + Send, ) -> Result<(), McpError>

Start serving MCP over WebSocket on the given address.

async fn serve_websocket_with_buffer( self, addr: impl Into<SocketAddr> + Send, buffer_size: usize, ) -> Result<(), McpError>

Start serving MCP over WebSocket with a custom notification channel buffer size.