Enum HandlerCommand 

pub enum HandlerCommand {
    SetClient(WebSocketClient),
    Disconnect,
    Subscribe {
        subscriptions: Vec<SubscriptionRequest>,
    },
    Unsubscribe {
        subscriptions: Vec<SubscriptionRequest>,
    },
    InitializeInstruments(Vec<InstrumentAny>),
    UpdateInstrument(InstrumentAny),
    AddBarType {
        key: String,
        bar_type: BarType,
    },
    RemoveBarType {
        key: String,
    },
    UpdateAssetContextSubs {
        coin: Ustr,
        data_types: AHashSet<AssetContextDataType>,
    },
    CacheSpotFillCoins(AHashMap<Ustr, Ustr>),
}

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>

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>

CacheSpotFillCoins(AHashMap<Ustr, Ustr>)

Cache spot fill coin mappings for instrument lookup.

Trait Implementations

impl Debug for HandlerCommand

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

Formats the value using the given formatter.