Struct BinanceConnectionManager 

pub struct BinanceConnectionManager { /* private fields */ }

Manages multiple WebSocket connections for Binance to handle sharding and isolation.

Connections are organized by market type (Spot, Swap, Futures, Option) to ensure that each market type connects to the correct WebSocket endpoint.

Implementations

impl BinanceConnectionManager

pub fn new(urls: BinanceUrls, is_sandbox: bool) -> Self

Creates a new connection manager with the given URLs.

pub fn production() -> Self

Creates a new connection manager for production environment.

pub fn testnet() -> Self

Creates a new connection manager for testnet environment.

pub fn get_ws_url(&self, market_type: MarketType) -> &str

Returns the WebSocket URL for the given market type.

URL Routing

• MarketType::Spot → stream.binance.com (spot and margin trading)
• MarketType::Futures → fstream.binance.com (Linear/USDT-margined contracts)
• MarketType::Swap → dstream.binance.com (Inverse/Coin-margined contracts)
• MarketType::Option → nbstream.binance.com (European-style options)

Callers should select the MarketType based on the market’s linear/inverse flags:

• market.linear == true → use MarketType::Futures
• market.inverse == true → use MarketType::Swap

Arguments

• market_type - The market type to get the URL for

Returns

The WebSocket URL for the specified market type.

pub async fn get_public_connection( &self, market_type: MarketType, ) -> Result<Arc<BinanceWs>>

Gets or creates a public connection suitable for a new subscription.

Connections are lazily initialized on first subscription for each market type.

Arguments

• market_type - The market type for the connection

Returns

An Arc to the WebSocket client for the specified market type.

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

Gets or creates the dedicated private connection for the given market type.

Arguments

• market_type - The market type for the connection
• binance - Reference to the Binance instance for authentication

Returns

An Arc to the authenticated WebSocket client.

pub async fn active_shards_count(&self) -> usize

Returns the number of active public shards across all market types.

pub async fn active_shards_count_for(&self, market_type: MarketType) -> usize

Returns the number of active public shards for a specific market type.

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

Disconnects all active connections across all market types.

pub async fn disconnect_market(&self, market_type: MarketType) -> Result<()>

Disconnects all connections for a specific market type.

pub fn is_connected(&self) -> bool

Checks if any connection is active (non-blocking).

pub fn is_connected_for(&self, market_type: MarketType) -> bool

Checks if a connection is active for a specific market type (non-blocking).

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

Returns a list of all active subscriptions across all connections.

pub fn get_subscriptions_for(&self, market_type: MarketType) -> Vec<String>

Returns a list of active subscriptions for a specific market type.

pub fn urls(&self) -> &BinanceUrls

Returns a reference to the URLs configuration.

pub fn is_sandbox(&self) -> bool

Returns whether this manager is configured for sandbox/testnet.

Trait Implementations

impl Debug for BinanceConnectionManager

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

Formats the value using the given formatter.