Struct StreamState 

pub struct StreamState {
    pub stream_id: Option<u64>,
    pub update_clk: Option<Clock>,
    pub max_latency_ms: Option<u64>,
    pub unique_id: Option<i32>,
    pub initial_clock: Option<InitialClock>,
    pub time_created: DateTime<Utc>,
    pub time_updated: DateTime<Utc>,
    pub market_stream_tracker: MarketStreamTracker,
    pub order_stream_tracker: OrderStreamTracker,
}

Separate stream struct to hold market/order caches

Fields

stream_id: Option<u64>

update_clk: Option<Clock>

max_latency_ms: Option<u64>

unique_id: Option<i32>

initial_clock: Option<InitialClock>

time_created: DateTime<Utc>

time_updated: DateTime<Utc>

market_stream_tracker: MarketStreamTracker

order_stream_tracker: OrderStreamTracker

Implementations

impl StreamState

pub fn new() -> Self

pub fn order_change_update( &mut self, msg: OrderChangeMessage, ) -> Option<Vec<&OrderBookCache>>

pub fn market_change_update( &mut self, msg: MarketChangeMessage, ) -> Option<Vec<&MarketBookCache>>

Trait Implementations

impl Clone for StreamState

fn clone(&self) -> StreamState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamState

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

Formats the value using the given formatter.

impl Default for StreamState

fn default() -> Self

Returns the “default value” for a type.