Struct WebSocketConnector

#[repr(align(64))]
pub struct WebSocketConnector { /* private fields */ }

WebSocket connector with advanced features

Implementations

impl WebSocketConnector

pub fn new( config: WebSocketConfig, stats: SharedStats, connection_status: Arc<RwLock<ConnectionState>>, ) -> Self

Create a new WebSocket connector

pub const fn config(&self) -> &WebSocketConfig

Get the configuration

pub fn get_batch_metrics(&self) -> BatchProcessingMetrics

Get batch processing metrics

pub fn create_websocket_options( exchange_config: Option<&ExchangeConfig>, ) -> Options

Create WebSocket options with exchange-specific settings

pub async fn process_message_batch<T, P, R>( &self, messages: Vec<Message>, process_message: P, sender: &Sender<T>, ) -> WebSocketResult<usize>

where T: Send + 'static, P: Fn(&str, &Clock) -> Option<R> + Send + Sync, R: Into<T> + Send,

Process a batch of messages

pub async fn connect_with_retry( &mut self, url: &str, ) -> WebSocketResult<(WebSocketSink, WebSocketStream)>

Connect with retry and failover support

pub fn create_websocket_task<T, P, R>( &self, url: String, subscription_message: String, process_message: P, sender: Sender<T>, stop_receiver: &mut Receiver<bool>, ) -> JoinHandle<()>

where T: Send + 'static, P: Fn(&str, &Clock) -> Option<R> + Send + Sync + 'static, R: Into<T> + Send + 'static,

Create a WebSocket handler task

Trait Implementations

impl Debug for WebSocketConnector

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

Formats the value using the given formatter.