pub enum NautilusWsMessage {
Data(Vec<Data>),
Deltas(Box<OrderBookDeltas>),
Order(Box<OrderStatusReport>),
Fill(Box<FillReport>),
Position(Box<PositionStatusReport>),
AccountState(Box<AccountState>),
SubaccountSubscribed(Box<DydxWsSubaccountsSubscribed>),
SubaccountsChannelData(Box<DydxWsSubaccountsChannelData>),
OraclePrices(HashMap<String, DydxOraclePriceMarket>),
Error(DydxWebSocketError),
Reconnected,
}Expand description
Nautilus domain message emitted after parsing dYdX WebSocket events.
This enum contains fully-parsed Nautilus domain objects ready for consumption by the Python layer without additional processing.
Variants§
Data(Vec<Data>)
Market data (trades, quotes, bars).
Deltas(Box<OrderBookDeltas>)
Order book deltas.
Order(Box<OrderStatusReport>)
Order status reports from subaccount stream.
Fill(Box<FillReport>)
Fill reports from subaccount stream.
Position(Box<PositionStatusReport>)
Position status reports from subaccount stream.
AccountState(Box<AccountState>)
Account state updates from subaccount stream.
SubaccountSubscribed(Box<DydxWsSubaccountsSubscribed>)
Raw subaccount subscription with full state (for execution client parsing).
SubaccountsChannelData(Box<DydxWsSubaccountsChannelData>)
Raw subaccounts channel data (orders/fills) for execution client parsing.
OraclePrices(HashMap<String, DydxOraclePriceMarket>)
Oracle price updates from markets channel (for execution client).
Error(DydxWebSocketError)
Error message.
Reconnected
Reconnection notification.
Trait Implementations§
Source§impl Clone for NautilusWsMessage
impl Clone for NautilusWsMessage
Source§fn clone(&self) -> NautilusWsMessage
fn clone(&self) -> NautilusWsMessage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for NautilusWsMessage
impl RefUnwindSafe for NautilusWsMessage
impl Send for NautilusWsMessage
impl Sync for NautilusWsMessage
impl Unpin for NautilusWsMessage
impl UnwindSafe for NautilusWsMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].