Struct BinanceConnectionManager 

pub struct BinanceConnectionManager { /* private fields */ }

Manages multiple WebSocket connections for Binance to handle sharding and isolation

Implementations

impl BinanceConnectionManager

pub fn new(base_ws_url: String) -> Self

Creates a new connection manager

pub async fn get_public_connection(&self) -> Result<Arc<BinanceWs>>

Gets or creates a public connection suitable for a new subscription

pub async fn get_private_connection( &self, binance: &Arc<Binance>, ) -> Result<Arc<BinanceWs>>

Gets or creates the dedicated private connection

pub async fn active_shards_count(&self) -> usize

Returns the number of active public shards

pub async fn disconnect_all(&self) -> Result<()>

Disconnects all active connections

pub fn is_connected(&self) -> bool

Checks if any connection is active (non-blocking)

pub fn get_all_subscriptions(&self) -> Vec<String>

Returns a list of all active subscriptions across all connections

Trait Implementations

impl Debug for BinanceConnectionManager

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

Formats the value using the given formatter.