Enum HandlerCommand 

pub enum HandlerCommand {
    SetClient(WebSocketClient),
    Disconnect,
    Subscribe {
        subscriptions: Vec<SubscriptionRequest>,
    },
    Unsubscribe {
        subscriptions: Vec<SubscriptionRequest>,
    },
    Post {
        id: u64,
        request: PostRequest,
    },
    InitializeInstruments(Vec<InstrumentAny>),
    UpdateInstrument(InstrumentAny),
    AddBarType {
        key: String,
        bar_type: BarType,
    },
    RemoveBarType {
        key: String,
    },
    UpdateAssetContextSubs {
        coin: Ustr,
        data_types: AHashSet<AssetContextDataType>,
    },
    UpdateTradeSubs {
        coin: Ustr,
        uses: TradeStreamUses,
    },
    CacheAllDexAssetCtxsInstrumentIds(AHashMap<Ustr, Vec<Option<InstrumentId>>>),
    CacheSpotFillCoins(AHashMap<Ustr, Ustr>),
    SetDepth10Sub {
        coin: Ustr,
        subscribed: bool,
    },
}

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

Variants

SetClient(WebSocketClient)

Set the WebSocketClient for the handler to use.

Disconnect

Disconnect the WebSocket connection.

Subscribe

Subscribe to the given subscriptions.

Fields

subscriptions: Vec<SubscriptionRequest>

Unsubscribe

Unsubscribe from the given subscriptions.

Fields

subscriptions: Vec<SubscriptionRequest>

Post

Send a WebSocket post request.

Fields

id: u64

request: PostRequest

InitializeInstruments(Vec<InstrumentAny>)

Initialize the instruments cache with the given instruments.

UpdateInstrument(InstrumentAny)

Update a single instrument in the cache.

AddBarType

Add a bar type mapping for candle parsing.

Fields

key: String

bar_type: BarType

RemoveBarType

Remove a bar type mapping.

Fields

key: String

UpdateAssetContextSubs

Update asset context subscriptions for a coin.

Fields

coin: Ustr

data_types: AHashSet<AssetContextDataType>

UpdateTradeSubs

Update the logical consumers of a trades stream for a coin.

Fields

coin: Ustr

uses: TradeStreamUses

CacheAllDexAssetCtxsInstrumentIds(AHashMap<Ustr, Vec<Option<InstrumentId>>>)

Cache the ordered instrument IDs needed to normalize allDexsAssetCtxs.

CacheSpotFillCoins(AHashMap<Ustr, Ustr>)

Cache spot fill coin mappings for instrument lookup.

SetDepth10Sub

Flag whether the l2Book stream for coin should also be emitted as NautilusWsMessage::Depth10 snapshots.

Fields

coin: Ustr

subscribed: bool

Trait Implementations

impl Debug for HandlerCommand

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

Formats the value using the given formatter.