Struct crypto_ws_client::OkexWSClient

pub struct OkexWSClient { /* private fields */ }

The WebSocket client for OKEx.

OKEx has Spot, Future, Swap and Option markets.

• WebSocket API doc: https://www.okex.com/docs/en/
• Trading at:
  • Spot https://www.okex.com/trade-spot
  • Future https://www.okex.com/trade-futures
  • Swap https://www.okex.com/trade-swap
  • Option https://www.okex.com/trade-option

Implementations

impl OkexWSClient

pub 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 OkexWSClient

fn subscribe_trade(&self, channels: &[String])

Subscribes to trade channels.

fn subscribe_orderbook(&self, channels: &[String])

Subscribes to incremental level2 orderbook channels.

fn subscribe_orderbook_topk(&self, channels: &[String])

Subscribes to level2 orderbook snapshot channels.

fn subscribe_l3_orderbook(&self, channels: &[String])

Subscribes to level3 orderebook channels.

fn subscribe_ticker(&self, channels: &[String])

Subscribes to ticker channels.

fn subscribe_bbo(&self, channels: &[String])

Subscribes to BBO(best bid & offer) channels.

fn subscribe_candlestick(&self, symbol_interval_list: &[(String, usize)])

Subscribes to candlestick channels.

fn subscribe(&self, channels: &[String])

Subscribes to raw channels, lower level API.

fn unsubscribe(&self, channels: &[String])

Unsubscribes from raw channels, lower level API.

fn run(&self, duration: Option<u64>)

Starts the infinite loop until time is up or the server closes the connection.

fn close(&self)

Breaks the loop and closes the connection.