Struct OcmState 

pub struct OcmState {
    pub fill_tracker: FillTracker,
    pub terminal_orders: AHashSet<BetId>,
    pub replaced_venue_order_ids: AHashSet<BetId>,
    /* private fields */
}

Shared mutable state for the OCM stream handler.

Accessed by both the TCP reader closure and the execution client methods (submit, modify, connect/disconnect). All access goes through Arc<Mutex<>>.

Terminal retention owns order correlation, per-Bet fill and reduction state, and replacement history. The first REST, OCM, or reconciliation observation with active quantity at least the requested quantity and below the original confirms a pending reduction; later observations are no-ops.

Fields

fill_tracker: FillTracker

Tracks cumulative per-bet fill and void state for deduplication and reconciliation.

terminal_orders: AHashSet<BetId>

Bet IDs that have received a terminal event (cancel, lapse, fill-complete).

replaced_venue_order_ids: AHashSet<BetId>

Old bet IDs from replace operations, to suppress late stream updates.

Implementations

impl OcmState

pub fn register_customer_order_ref(&mut self, client_order_id: ClientOrderId)

Registers a customer_order_ref mapping for a new order.

pub fn register_customer_order_ref_with_legacy( &mut self, client_order_id: ClientOrderId, )

Registers both current and legacy customer_order_ref truncations.

pub fn register_order_identity( &mut self, client_order_id: ClientOrderId, strategy_id: StrategyId, )

Records the submitting strategy for a tracked order.

pub fn order_strategy_id( &self, client_order_id: &ClientOrderId, ) -> Option<StrategyId>

Returns the submitting strategy for a tracked order, if known.

pub fn mark_accepted(&mut self, client_order_id: ClientOrderId) -> bool

Records that acceptance has been emitted for a tracked order.

Returns true when this call newly marks the order accepted (the caller should emit OrderAccepted), or false when acceptance was already emitted.

pub fn remove_customer_order_refs(&mut self, client_order_id: &ClientOrderId)

Removes customer_order_ref mappings for a client_order_id.

pub fn resolve_client_order_id( &self, rfo: Option<&str>, ) -> Option<ClientOrderId>

Resolves a client_order_id from the unmatched order’s rfo field.

pub fn should_suppress_cancel( &self, client_order_id: &ClientOrderId, bet_id: &str, ) -> bool

Returns true if a cancel/lapse for this bet should be suppressed because a replace operation is pending or the bet was already replaced.

pub fn mark_terminal_order(&mut self, bet_id: String)

Records an external terminal bet and bounds its stream and REST dedup state.

pub fn sync_from_orders(&mut self, orders: &[OrderSyncEntry])

Anchors the fill tracker against cached orders so the post-reconnect image neither treats cumulative size as a new fill nor re-emits a fill that was published via another channel.

Trait Implementations

impl Clone for OcmState

fn clone(&self) -> OcmState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OcmState

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

Formats the value using the given formatter.

impl Default for OcmState

fn default() -> OcmState

Returns the “default value” for a type.