Struct HttpClientTransport 

pub struct HttpClientTransport { /* private fields */ }

HTTP transport for MCP clients

This transport communicates with an MCP server via HTTP requests and optionally uses Server-Sent Events for real-time notifications.

Implementations

impl HttpClientTransport

pub async fn new<S: AsRef<str>>( base_url: S, sse_url: Option<S>, ) -> McpResult<Self>

Create a new HTTP client transport

Arguments

• base_url - Base URL for the MCP server
• sse_url - Optional URL for Server-Sent Events (for notifications)

Returns

Result containing the transport or an error

pub async fn with_config<S: AsRef<str>>( base_url: S, sse_url: Option<S>, config: TransportConfig, ) -> McpResult<Self>

Create a new HTTP client transport with custom configuration

Arguments

• base_url - Base URL for the MCP server
• sse_url - Optional URL for Server-Sent Events
• config - Transport configuration

Returns

Result containing the transport or an error

pub async fn with_mtls<S: AsRef<str>>( base_url: S, sse_url: Option<S>, config: TransportConfig, mtls: MtlsClientConfig, ) -> McpResult<Self>

Create an HTTP client that presents a certificate and validates the server against the supplied private CA.

pub async fn next_request_id(&self) -> u64

pub async fn active_request_count(&self) -> usize

Get count of active requests (for debugging/metrics)

impl HttpClientTransport

Production-grade convenience methods for HttpClientTransport

pub async fn ping(&mut self) -> McpResult<Duration>

Send a health check request and measure response time

pub async fn get_server_info(&mut self) -> McpResult<ServerInfo>

Retrieve server capabilities and version information

pub async fn get_connection_stats(&self) -> ConnectionStats

Get connection statistics for monitoring

pub fn is_healthy(&self) -> bool

Quick health check based on recent activity

pub async fn call_method<T: Serialize, R: for<'de> Deserialize<'de>>( &mut self, method: &str, params: T, ) -> McpResult<R>

Type-safe method calling with automatic serialization

pub async fn call_method_simple(&mut self, method: &str) -> McpResult<Value>

Simple method call without parameters

pub async fn batch_requests( &mut self, requests: Vec<JsonRpcRequest>, ) -> McpResult<Vec<JsonRpcResponse>>

Send multiple requests efficiently

pub async fn reconnect(&mut self) -> McpResult<()>

Reconnect with same configuration

pub async fn test_connection(&self) -> McpResult<bool>

Test if connection is working without modifying state

pub fn update_headers(&mut self, new_headers: HashMap<String, String>)

Update headers without recreating transport

pub fn set_timeout(&mut self, timeout_ms: u64)

Update timeout configuration

pub fn get_config(&self) -> &TransportConfig

Access current configuration

pub fn get_base_url(&self) -> &str

Get current base URL

pub fn get_sse_url(&self) -> Option<&str>

Get current SSE URL

pub fn get_endpoints(&self) -> HttpEndpoints

Get all endpoint URLs

pub async fn call_with_retry<T: Serialize + Clone, R: for<'de> Deserialize<'de>>( &mut self, method: &str, params: T, retry_config: RetryConfig, ) -> McpResult<R>

Method call with automatic retry logic

pub fn set_retry_policy(&mut self, _policy: RetryPolicy)

Set retry policy for automatic retries (would require state extension)

pub fn enable_request_logging(&mut self, _enabled: bool)

Enable/disable request/response logging (placeholder)

pub fn get_last_error(&self) -> Option<&McpError>

Get the last error that occurred (placeholder)

pub async fn export_metrics(&self) -> McpResult<TransportMetrics>

Export detailed metrics for monitoring (placeholder)

impl HttpClientTransport

pub fn builder() -> HttpClientTransportBuilder

Create a new builder for HttpClientTransport

Trait Implementations

impl Debug for HttpClientTransport

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

Formats the value using the given formatter.

impl Transport for HttpClientTransport

fn send_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,

Send a JSON-RPC request and wait for a response

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 (no response expected)

fn receive_notification<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcNotification>>> + Send + 'async_trait>>

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

Receive a notification from the server (non-blocking)

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

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

Open a modern long-lived subscription stream.

fn cancel_subscription<'life0, 'life1, 'async_trait>( &'life0 mut self, request_id: &'life1 Value, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Cancel an open subscription. HTTP implementations close the response stream; STDIO implementations send notifications/cancelled.

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

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

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn connection_info(&self) -> String

Get connection information for debugging

fn handle_incoming_request<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcRequest>>> + Send + 'async_trait>>

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

Handle incoming server request (for bidirectional communication)

fn send_response<'life0, 'async_trait>( &'life0 mut self, _response: JsonRpcResponse, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Send response to server request (for bidirectional communication)