Struct WsDispatchState 

pub struct WsDispatchState {
    pub order_identities: DashMap<ClientOrderId, OrderIdentity>,
    pub pending_requests: DashMap<String, PendingRequest>,
    pub cancel_replace_request_ids: DashMap<String, String>,
    /* private fields */
}

Tracks order lifecycle state for dispatch routing.

Orders with a registered identity produce typed order events. Untracked orders fall back to execution reports for reconciliation. For restored orders, accepted and filled state, plus the trade IDs known at restoration, remain available until terminal cleanup, independent of the bounded deduplication caches.

Fields

order_identities: DashMap<ClientOrderId, OrderIdentity>

pending_requests: DashMap<String, PendingRequest>

cancel_replace_request_ids: DashMap<String, String>

Cancel-replace request IDs mapped to their cancelNewClientOrderId.

Implementations

impl WsDispatchState

pub fn has_emitted_accepted(&self, cid: &ClientOrderId) -> bool

pub fn insert_accepted(&self, cid: ClientOrderId)

Marks an order as having emitted an OrderAccepted event.

pub fn has_filled(&self, cid: &ClientOrderId) -> bool

pub fn insert_filled(&self, cid: ClientOrderId)

Marks an order as having received a fill.

pub fn insert_cancel_replace(&self, cancel_id: String)

Records the cancelNewClientOrderId sent with a cancel-replace request.

pub fn has_cancel_replace(&self, cancel_id: &str) -> bool

Returns true when cancel_id belongs to a cancel-replace this client issued.

pub fn on_cancel_replace_canceled( &self, cancel_id: &str, report: OrderStatusReport, ) -> bool

Records the cancel half’s CANCELED report for a cancel-replace request.

Returns true when the report must be withheld because the replacement is pending or succeeded, and false when it should dispatch as a standalone cancel because the venue already rejected the replacement or the ID is not one this client issued.

pub fn on_cancel_replace_rejected( &self, cancel_id: &str, ) -> Option<OrderStatusReport>

Records a rejected cancel-replace request.

Returns the withheld cancel report when it already arrived, so the caller can emit the confirmed cancellation for the original order.

pub fn insert_algo_order_id( &self, cid: ClientOrderId, venue_order_id: VenueOrderId, )

pub fn promote_algo_order_id( &self, cid: ClientOrderId, venue_order_id: VenueOrderId, ) -> Option<bool>

Promotes a known Algo order to its matching-engine venue order ID.

Returns None for an unknown Algo order, Some(true) for a new ID, and Some(false) when the ID was already current.

pub fn promoted_algo_order_id( &self, cid: &ClientOrderId, ) -> Option<VenueOrderId>

Returns the matching-engine venue order ID for a promoted Algo order.

pub fn cleanup_terminal(&self, cid: ClientOrderId)

Removes all tracking state for a terminal order.

Trait Implementations

impl Debug for WsDispatchState

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

Formats the value using the given formatter.

impl Default for WsDispatchState

fn default() -> Self

Returns the “default value” for a type.