Enum NautilusWsMessage 

pub enum NautilusWsMessage {
    Trades(Vec<TradeTick>),
    Quote(QuoteTick),
    Deltas(OrderBookDeltas),
    Depth10(Box<OrderBookDepth10>),
    Bar(Bar),
    MarkPrice(MarkPriceUpdate),
    IndexPrice(IndexPriceUpdate),
    FundingRate(FundingRateUpdate),
    ExecutionReports(Vec<ExecutionReport>),
    PositionSnapshot {
        reports: Vec<PositionStatusReport>,
        skipped_market_ids: Vec<i16>,
    },
    AccountState(Box<AccountState>),
    SendTxAck {
        tx_hash: Option<String>,
        code: i64,
    },
    SendTxRejected {
        source: SendTxRejectionSource,
        code: Option<i64>,
        message: String,
        tx_hash: Option<String>,
    },
    Raw(Value),
    Reconnected,
    AccountStreamFirstFrame(AccountStream),
}

Inbound message produced by the Lighter feed handler and consumed by the data and execution clients.

Account-stream variants carry typed Nautilus reports so that the execution client can route them without re-parsing. Fills can arrive on both account_orders (as the embedded fill quantity) and account_all_trades (as discrete trade prints); the handler emits both untouched and the execution-side consumer is responsible for cross-source dedup.

Variants

Trades(Vec<TradeTick>)

Quote(QuoteTick)

Deltas(OrderBookDeltas)

Depth10(Box<OrderBookDepth10>)

Bar(Bar)

MarkPrice(MarkPriceUpdate)

IndexPrice(IndexPriceUpdate)

FundingRate(FundingRateUpdate)

ExecutionReports(Vec<ExecutionReport>)

PositionSnapshot

Fields

reports: Vec<PositionStatusReport>

skipped_market_ids: Vec<i16>

AccountState(Box<AccountState>)

SendTxAck

Fields

tx_hash: Option<String>

code: i64

SendTxRejected

Fields

source: SendTxRejectionSource

code: Option<i64>

message: String

tx_hash: Option<String>

Raw(Value)

Reconnected

AccountStreamFirstFrame(AccountStream)

Marker emitted by the feed handler right after each account stream has delivered its first frame. The execution consumption loop forwards any preceding typed reports first, then marks the corresponding readiness flag, keeping connect() blocked until applied state is observable to strategies.

Trait Implementations

impl Clone for NautilusWsMessage

fn clone(&self) -> NautilusWsMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NautilusWsMessage

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

Formats the value using the given formatter.