Struct ExecutionHarness 

pub struct ExecutionHarness { /* private fields */ }

Engine-wired state for deterministic live execution seam tests.

Implementations

impl ExecutionHarness

pub fn new( trader_id: TraderId, client_id: ClientId, account_id: AccountId, instrument: InstrumentAny, ) -> Self

Creates a harness with real risk and execution engines and the supplied instrument.

Replaces the current thread’s message bus and live event senders.

pub const fn clock(&self) -> &Rc<RefCell<dyn Clock>>

Returns the clock shared by the harness components.

pub const fn cache(&self) -> &Rc<RefCell<Cache>>

Returns the cache shared by the harness components.

pub const fn risk_engine(&self) -> &Rc<RefCell<RiskEngine>>

Returns the risk engine used to route trading commands.

pub const fn exec_engine(&self) -> &Rc<RefCell<ExecutionEngine>>

Returns the execution engine containing the adapter client under test.

pub const fn trader_id(&self) -> TraderId

Returns the trader ID used by the harness.

pub const fn client_id(&self) -> ClientId

Returns the execution client ID used by the harness.

pub const fn account_id(&self) -> AccountId

Returns the account ID used by the harness.

pub const fn instrument_id(&self) -> InstrumentId

Returns the instrument ID registered in the cache.

pub fn routed(&self) -> &[RoutedKind]

Returns the routing kinds observed before live-runner dispatch.

pub fn assert_engine_ready(&self)

Asserts that the execution client is registered and its engine is ready.

pub fn risk_command_count(&self) -> u64

Returns the total commands received by the risk engine.

pub fn register_client(&self, client: Box<dyn ExecutionClient>) -> Result<()>

Registers an adapter execution client and its native venue route with the execution engine.

Errors

Returns an error when the engine already contains the client ID or venue route.

pub fn submit_via_risk(&self, order: &OrderAny)

Caches an order and sends its submission command through the risk engine.

pub fn modify_via_risk( &self, order: &OrderAny, price: Option<Price>, quantity: Option<Quantity>, )

Marks an order pending update and sends its modification through the risk engine.

pub fn cancel_via_execution(&self, order: &OrderAny)

Marks an order pending cancel and sends its cancellation through the execution engine.

pub async fn pump_until( &mut self, timeout: Duration, predicate: impl Fn(&Cache) -> bool, ) -> bool

Routes emitted execution events until the cache predicate holds or the deadline expires.

pub async fn pump_until_routed( &mut self, timeout: Duration, kind: RoutedKind, ) -> bool

Routes emitted execution events until the expected routing kind is observed.

pub async fn pump_for(&mut self, duration: Duration)

Routes every execution event received during the supplied duration.

pub fn register_exec_tester( &self, strategy_id: StrategyId, order_qty: Quantity, ) -> ExecTester

Registers an ExecTester against the harness clock and cache.

pub fn mark_pending_cancel(&self, order: &OrderAny)

Applies a pending-cancel event to the cached order.

pub async fn reconcile_from_venue(&self) -> ExecutionMassStatus

Generates and applies execution mass status from the registered adapter client.

Trait Implementations

impl Debug for ExecutionHarness

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

Formats the value using the given formatter.