Enum HandlerCommand 

pub enum HandlerCommand {
    SetClient(WebSocketClient),
    Disconnect,
    Subscribe {
        channel: LighterWsChannel,
        auth: Option<String>,
    },
    Unsubscribe {
        channel: LighterWsChannel,
    },
    ResubscribeOrderBook {
        market_index: i16,
    },
    InitializeInstruments(Vec<(i16, InstrumentAny)>),
    UpdateInstrument {
        market_index: i16,
        instrument: InstrumentAny,
    },
    SetBookDeltasSub {
        market_index: i16,
        subscribed: bool,
    },
    SetDepth10Sub {
        market_index: i16,
        subscribed: bool,
    },
    SetExecutionContext {
        account_id: AccountId,
        account_index: i64,
    },
    SendTx {
        tx_type: u8,
        tx_info: Box<RawValue>,
        response_tx: Sender<Result<(), LighterWsError>>,
    },
}

Commands sent from the outer client to the inner feed handler.

Variants

SetClient(WebSocketClient)

Hand the live WebSocketClient to the handler after the outer client completes the network connect.

Disconnect

Drain the queue and shut the handler down.

Subscribe

Subscribe to a channel. auth carries an optional auth token for the account-scoped channels.

Fields

channel: LighterWsChannel

auth: Option<String>

Unsubscribe

Unsubscribe from a channel.

Fields

channel: LighterWsChannel

ResubscribeOrderBook

Resubscribe to the venue order_book stream after a continuity gap.

Fields

market_index: i16

InitializeInstruments(Vec<(i16, InstrumentAny)>)

Replace the handler’s instrument cache (used on initial connect).

UpdateInstrument

Insert or replace a single instrument by market_index.

Fields

market_index: i16

instrument: InstrumentAny

SetBookDeltasSub

Toggle whether update/order_book frames for market_index should be emitted as NautilusWsMessage::Deltas.

Fields

market_index: i16

subscribed: bool

SetDepth10Sub

Toggle whether update/order_book frames for market_index should also be emitted as a NautilusWsMessage::Depth10 snapshot.

Fields

market_index: i16

subscribed: bool

SetExecutionContext

Provide the execution context (AccountId and venue account_index) the handler stamps onto reports parsed from account_* frames. Without this context the handler cannot construct typed reports and account frames are forwarded as raw JSON instead.

Fields

account_id: AccountId

account_index: i64

SendTx

Dispatch a signed L2 transaction over the WebSocket.

The handler serializes a LighterWsRequest::SendTx frame; the venue confirms acceptance via the account_* streams (and reports any rejection via a control-plane error frame).

Fields

tx_type: u8

tx_info: Box<RawValue>

response_tx: Sender<Result<(), LighterWsError>>

Trait Implementations

impl Debug for HandlerCommand

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

Custom Debug that redacts the auth field of Subscribe. The command is routed in-process via mpsc and may be printed by error paths or trace logging; deriving Debug would otherwise leak the venue bearer token verbatim.