Enum DydxWsOutputMessage 

pub enum DydxWsOutputMessage {
    Trades {
        id: String,
        contents: DydxTradeContents,
    },
    OrderbookSnapshot {
        id: String,
        contents: DydxOrderbookSnapshotContents,
    },
    OrderbookUpdate {
        id: String,
        contents: DydxOrderbookContents,
    },
    OrderbookBatch {
        id: String,
        updates: Vec<DydxOrderbookContents>,
    },
    Candles {
        id: String,
        contents: DydxCandle,
    },
    Markets(DydxMarketsContents),
    SubaccountSubscribed(Box<DydxWsSubaccountsSubscribed>),
    SubaccountsChannelData(Box<DydxWsSubaccountsChannelData>),
    BlockHeight {
        height: u64,
        time: DateTime<Utc>,
    },
    Error(DydxWebSocketError),
    Reconnected,
}

Venue-specific message emitted by the handler to consumers.

The handler deserializes raw WebSocket JSON into these typed variants without converting to Nautilus domain types. Consumers (data client, execution client, Python bindings) perform the final conversion using their own instrument caches.

Variants

Trades

Trade data for a market.

Fields

id: String

contents: DydxTradeContents

OrderbookSnapshot

Order book snapshot (initial subscription).

Fields

id: String

contents: DydxOrderbookSnapshotContents

OrderbookUpdate

Order book delta update.

Fields

id: String

contents: DydxOrderbookContents

OrderbookBatch

Order book batch update (multiple deltas).

Fields

id: String

updates: Vec<DydxOrderbookContents>

Candles

Candle data for a market.

Fields

id: String

contents: DydxCandle

Markets(DydxMarketsContents)

Markets channel data (oracle prices, trading, instrument status).

SubaccountSubscribed(Box<DydxWsSubaccountsSubscribed>)

Subaccount subscription with initial account state.

SubaccountsChannelData(Box<DydxWsSubaccountsChannelData>)

Subaccount channel data (orders, fills).

BlockHeight

Block height update from chain.

Fields

height: u64

time: DateTime<Utc>

Error(DydxWebSocketError)

Error from the venue or handler.

Reconnected

Reconnection notification.

Trait Implementations

impl Clone for DydxWsOutputMessage

fn clone(&self) -> DydxWsOutputMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DydxWsOutputMessage

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

Formats the value using the given formatter.