Struct ReconciliationManager 

pub struct ReconciliationManager { /* private fields */ }

Manager for reconciling execution state between local cache and venues.

The ReconciliationManager handles:

• Startup reconciliation to align state on system start
• Continuous reconciliation of inflight orders
• External order discovery and claiming
• Fill report processing and validation

Implementations

impl ReconciliationManager

pub fn new( clock: Rc<RefCell<dyn Clock>>, cache: Rc<RefCell<Cache>>, config: ReconciliationConfig, ) -> Self

Creates a new ReconciliationManager instance.

pub async fn reconcile_execution_mass_status( &mut self, mass_status: ExecutionMassStatus, ) -> Vec<OrderEventAny>

Reconciles orders and fills from a mass status report.

pub fn reconcile_report( &mut self, report: ExecutionReport, ) -> Vec<OrderEventAny>

Reconciles a single execution report during runtime.

pub fn check_inflight_orders(&mut self) -> Vec<OrderEventAny>

Checks inflight orders and returns events for any that need reconciliation.

pub async fn check_open_orders(&mut self) -> Vec<OrderEventAny>

Checks open orders against the venue state.

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

Registers an order as inflight for tracking.

pub fn claim_external_orders( &mut self, instrument_id: InstrumentId, strategy_id: StrategyId, )

Claims external orders for a specific strategy and instrument.

Trait Implementations

impl Clone for ReconciliationManager

fn clone(&self) -> ReconciliationManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReconciliationManager

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

Formats the value using the given formatter.