Struct HttpTransportServer 

pub struct HttpTransportServer { /* private fields */ }

HTTP transport server implementation

Implementations

impl HttpTransportServer

pub fn new(config: HttpTransportConfig) -> HttpTransportServer

pub fn with_metrics(self, metrics: Arc<MetricsCollector>) -> HttpTransportServer

pub fn with_monitoring( self, monitoring: Arc<MonitoringSystem>, ) -> HttpTransportServer

pub fn get_message_receiver(&self) -> Receiver<(String, JsonRpcMessage)>

pub fn get_message_sender(&self) -> Sender<(String, JsonRpcMessage)>

pub fn get_response_sender(&self) -> Sender<(String, JsonRpcMessage)>

pub fn get_state(&self) -> HttpTransportState

pub fn get_metrics(&self) -> Option<Arc<MetricsCollector>>

pub fn get_monitoring(&self) -> Option<Arc<MonitoringSystem>>

pub async fn run(self) -> Result<(), TransportError>

Trait Implementations

impl Transport for HttpTransportServer

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

where 'life0: 'async_trait, HttpTransportServer: 'async_trait,

Send a message through the transport

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

where 'life0: 'async_trait, HttpTransportServer: 'async_trait,

Receive a message from the transport

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

where 'life0: 'async_trait, HttpTransportServer: 'async_trait,

Close the transport connection gracefully

fn get_state(&self) -> ConnectionState

Get current connection state

fn get_health(&self) -> TransportHealth

Get transport health information

fn is_ready(&self) -> bool

Check if transport is ready for operations

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

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

Initiate graceful shutdown

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

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

Force immediate shutdown

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

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

Attempt to reconnect the transport

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

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

Reset transport state and clear any cached data