Struct HttpTransport 

pub struct HttpTransport { /* private fields */ }

HTTP transport for MCP protocol

Implements the MCP HTTP transport specification:

• HTTP POST for client-to-server messages
• Server-Sent Events (SSE) for server-to-client streaming
• Session management with Mcp-Session-Id header
• Origin validation and CORS support
• Authentication support

Implementations

impl HttpTransport

pub fn new(port: u16) -> Self

Create a new HTTP transport with default configuration

pub fn config(&self) -> &HttpConfig

Get the configuration

pub fn is_initialized(&self) -> bool

Check if the transport is initialized

pub fn is_running(&self) -> bool

Check if the server is running

pub async fn broadcast_message( &self, message: &str, ) -> Result<(), TransportError>

Send a message to all connected SSE clients

pub fn with_config(config: HttpConfig) -> Self

Create a new HTTP transport with custom configuration

pub fn validate_origin( config: &HttpConfig, headers: &HeaderMap, ) -> Result<(), TransportError>

Validate origin header

pub fn validate_auth( config: &HttpConfig, headers: &HeaderMap, ) -> Result<(), TransportError>

Validate authentication

Trait Implementations

impl Transport for HttpTransport

fn start<'life0, 'async_trait>( &'life0 mut self, handler: RequestHandler, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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