Struct TransportMonitoringMiddleware 

pub struct TransportMonitoringMiddleware { /* private fields */ }

Transport middleware for connection monitoring

Implementations

impl TransportMonitoringMiddleware

pub fn new( metrics_collector: Arc<MetricsCollector>, ) -> TransportMonitoringMiddleware

Create a new transport monitoring middleware

pub fn with_config( metrics_collector: Arc<MetricsCollector>, enabled: bool, ) -> TransportMonitoringMiddleware

Create a new transport monitoring middleware with custom settings

pub fn is_enabled(&self) -> bool

Check if the middleware is enabled

pub fn set_enabled(&mut self, enabled: bool)

Set whether the middleware is enabled

pub async fn process_connection( &self, connection_id: &str, event_type: ConnectionEvent, )

Process a transport connection event

pub async fn process_message( &self, connection_id: &str, event_type: MessageEvent, )

Process a transport message event