Struct CoinbaseProWSClient 

pub struct CoinbaseProWSClient { /* private fields */ }

The WebSocket client for CoinbasePro.

CoinbasePro has only Spot market.

• WebSocket API doc: https://docs.cloud.coinbase.com/exchange/docs/websocket-overview
• Trading at: https://pro.coinbase.com/

Implementations

impl CoinbaseProWSClient

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

Creates a websocket client.

Arguments

• tx - The sending part of a channel
• url - Optional server url, usually you don’t need specify it

Trait Implementations

impl WSClient for CoinbaseProWSClient

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().