Struct LiveExecutionEngine 

pub struct LiveExecutionEngine { /* private fields */ }

Live execution engine that manages execution state and reconciliation.

The LiveExecutionEngine orchestrates:

• Startup reconciliation with all venues.
• Continuous reconciliation of execution reports.
• Inflight order checking and resolution.
• Message routing between venues and the core execution engine.

Implementations

impl LiveExecutionEngine

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

Creates a new LiveExecutionEngine instance.

pub async fn start(&mut self) -> Result<()>

Starts the live execution engine.

This initiates:

• Startup reconciliation with all venues.
• Continuous reconciliation tasks.
• Message processing loops.

Errors

Returns an error if startup reconciliation fails.

pub async fn stop(&mut self) -> Result<()>

Stops the live execution engine.

Errors

Returns an error if stopping tasks fails.

pub fn reconcile_execution_report(&mut self, report: ExecutionReport)

Reconciles an execution report.

pub fn handle_command(&mut self, command: TradingCommand)

Handles a trading command.

pub fn record_local_activity(&mut self, event: &OrderEventAny)

Records local order activity for reconciliation tracking.

pub fn clear_reconciliation_tracking( &mut self, client_order_id: &ClientOrderId, drop_last_query: bool, )

Clears reconciliation tracking for an order.

pub fn is_running(&self) -> bool

Returns whether the engine is currently running.

Trait Implementations

impl Debug for LiveExecutionEngine

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

Formats the value using the given formatter.