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 (submitted through this client) produce proper order events. Orders without identity (external or pre-existing) fall back to execution reports for reconciliation.

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.