Expand description
Consolidated WebSocket implementation for all exchanges
This module provides a unified, high-performance WebSocket client implementation using yawc, with support for authentication, compression, automatic reconnection, and exchange-specific customizations.
Re-exports§
pub use auth::AuthMethod;pub use auth::DefaultWebSocketAuth;pub use auth::WebSocketAuth;pub use auth::create_authenticator;pub use batch::BatchProcessingMetrics;pub use batch::BatchProcessor;pub use bridge::ChannelBridgeHandler;pub use bridge::MessageRouter;pub use bridge::RoutedMessage;pub use bridge::SubscriptionChannel;pub use bridge::SubscriptionType;pub use client::ConnectionState;pub use client::WebSocketClient;pub use client::WebSocketStream;pub use config::CompressionConfig;pub use config::ReconnectConfig;pub use config::WebSocketConfig;pub use connector::WebSocketConnector;pub use connector::WebSocketSink;pub use error::WebSocketError;pub use error::WebSocketResult;pub use handler::ExchangeHandler;pub use handler::MessageHandler;pub use heartbeat::HeartbeatMonitor;pub use heartbeat::HeartbeatStatus;pub use message::Message;pub use message::MessageType;pub use reconnect::ReconnectStrategy;pub use stats::ConnectionStats;pub use utils::to_json;
Modules§
- auth
- WebSocket authentication module
- batch
- Batch processing support for WebSocket messages
- bridge
- Channel bridge for WebSocket client
- client
- WebSocket client implementation
- config
- WebSocket configuration
- connector
- WebSocket connector with advanced features
- error
- WebSocket error types
- exchanges
- Exchange-specific WebSocket implementations
- handler
- WebSocket message handlers
- heartbeat
- Heartbeat monitoring for WebSocket connections
- message
- WebSocket message types
- reconnect
- WebSocket reconnection strategies
- stats
- WebSocket connection statistics tracking
- utils
- WebSocket utility functions
- zerocopy_
frame - Zero-copy WebSocket frame parsing for ultra-fast binary protocol handling