Enum OKXWsMessage 

pub enum OKXWsMessage {
    BookData {
        arg: OKXWebSocketArg,
        action: OKXBookAction,
        data: Vec<OKXBookMsg>,
    },
    ChannelData {
        channel: OKXWsChannel,
        inst_id: Option<Ustr>,
        data: Value,
    },
    OrderResponse {
        id: Option<String>,
        op: OKXWsOperation,
        code: String,
        msg: String,
        data: Vec<Value>,
    },
    Orders(Vec<OKXOrderMsg>),
    AlgoOrders(Vec<OKXAlgoOrderMsg>),
    Account(Value),
    Positions(Value),
    Instruments(Vec<OKXInstrument>),
    SendFailed {
        request_id: String,
        client_order_id: Option<ClientOrderId>,
        op: Option<OKXWsOperation>,
        error: String,
    },
    Error(OKXWebSocketError),
    Reconnected,
    Authenticated,
}

Output from the OKX WebSocket handler.

Contains venue-specific types only. Data parsing occurs in PyOKXWebSocketClient (using an instruments cache), and execution parsing occurs in execution.rs (using the system Cache for order lookups).

Variants

BookData

Order book snapshot or update.

Fields

arg: OKXWebSocketArg

action: OKXBookAction

data: Vec<OKXBookMsg>

ChannelData

Data from a non-book channel (trades, tickers, mark price, funding, candles, etc.).

Fields

channel: OKXWsChannel

inst_id: Option<Ustr>

data: Value

OrderResponse

Response to a WebSocket order command (place, cancel, amend, mass-cancel).

Fields

id: Option<String>

op: OKXWsOperation

code: String

msg: String

data: Vec<Value>

Orders(Vec<OKXOrderMsg>)

Order push channel updates.

AlgoOrders(Vec<OKXAlgoOrderMsg>)

Algo order push channel updates.

Account(Value)

Account channel update (raw JSON).

Positions(Value)

Positions channel update (raw JSON).

Instruments(Vec<OKXInstrument>)

Instrument definition updates.

SendFailed

A WebSocket send failed; carries context for emitting the appropriate rejection event.

Fields

request_id: String

client_order_id: Option<ClientOrderId>

op: Option<OKXWsOperation>

error: String

Error(OKXWebSocketError)

Error received from OKX.

Reconnected

WebSocket reconnected.

Authenticated

WebSocket authenticated.

Trait Implementations

impl Debug for OKXWsMessage

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

Formats the value using the given formatter.