Struct BitgetSpotWSClient 

pub struct BitgetSpotWSClient { /* private fields */ }

The WebSocket client for Bitget Spot market.

• WebSocket API doc: https://bitgetlimited.github.io/apidoc/en/spot/#websocketapi
• Trading at: https://www.bitget.com/en/spot/

Implementations

impl BitgetSpotWSClient

pub async fn new(tx: Sender<String>, url: Option<&str>) -> Self

Trait Implementations

impl WSClient for BitgetSpotWSClient

fn subscribe_trade<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to trade channels.

fn subscribe_orderbook<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to incremental level2 orderbook channels.

fn subscribe_orderbook_topk<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to level2 orderbook snapshot channels.

fn subscribe_l3_orderbook<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to level3 orderebook channels.

fn subscribe_ticker<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to ticker channels.

fn subscribe_bbo<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to BBO(best bid & offer) channels.

fn subscribe_candlestick<'life0, 'life1, 'async_trait>( &'life0 self, symbol_interval_list: &'life1 [(String, usize)], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribes to candlestick channels.

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, topics: &'life1 [(String, String)], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe to multiple topics.

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, topics: &'life1 [(String, String)], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unsubscribes multiple topics.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, commands: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send raw JSON commands.

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts the infinite event loop.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the connection and break the loop in Run().