Struct StubExecutionClient 

pub struct StubExecutionClient { /* private fields */ }

A stub execution client for testing purposes.

This client provides a minimal implementation of the ExecutionClient trait that can be used in unit tests without requiring actual venue connectivity.

Implementations

impl StubExecutionClient

pub fn new( client_id: ClientId, account_id: AccountId, venue: Venue, oms_type: OmsType, clock: Option<Rc<RefCell<dyn Clock>>>, ) -> Self

Creates a new StubExecutionClient instance.

pub fn with_handles_all_order_venues(self) -> Self

Configures this stub to accept orders for any instrument venue.

pub fn with_submit_order_error(self, error: impl Into<String>) -> Self

Configures this stub to fail single-order submissions.

pub fn with_submit_order_list_error(self, error: impl Into<String>) -> Self

Configures this stub to fail order-list submissions.

pub fn received_instruments(&self) -> Rc<RefCell<Vec<InstrumentAny>>>

Returns a shared handle to the instruments delivered via [ExecutionClient::on_instrument].

pub fn submitted_order_ids(&self) -> Rc<RefCell<Vec<ClientOrderId>>>

Returns a shared handle to the submitted order IDs.

pub fn modified_order_ids(&self) -> Rc<RefCell<Vec<ClientOrderId>>>

Returns a shared handle to the modified order IDs.

pub fn queried_account_ids(&self) -> Rc<RefCell<Vec<AccountId>>>

Returns a shared handle to the queried account IDs.

pub fn start_count(&self) -> usize

Returns the number of times [ExecutionClient::start] was invoked.

pub fn stop_count(&self) -> usize

Returns the number of times [ExecutionClient::stop] was invoked.

pub fn reset_count(&self) -> usize

Returns the number of times [ExecutionClient::reset] was invoked.

pub fn dispose_count(&self) -> usize

Returns the number of times [ExecutionClient::dispose] was invoked.

Trait Implementations

impl Clone for StubExecutionClient

fn clone(&self) -> StubExecutionClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StubExecutionClient

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

Formats the value using the given formatter.

impl ExecutionClient for StubExecutionClient

fn is_connected(&self) -> bool

fn client_id(&self) -> ClientId

fn account_id(&self) -> AccountId

fn venue(&self) -> Venue

fn handles_order_venue(&self, venue: Venue) -> bool

Returns whether this client can execute orders for the given instrument venue.

fn oms_type(&self) -> OmsType

fn get_account(&self) -> Option<AccountAny>

fn generate_account_state( &self, _balances: Vec<AccountBalance>, _margins: Vec<MarginBalance>, _reported: bool, _ts_event: UnixNanos, ) -> Result<()>

Generates and publishes the account state event.

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

Starts the execution client.

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

Stops the execution client.

fn reset(&mut self) -> Result<()>

Resets the execution client to its initial state.

fn dispose(&mut self) -> Result<()>

Disposes of client resources and cleans up.

fn submit_order(&self, cmd: SubmitOrder) -> Result<()>

Submits a single order command to the execution venue.

fn submit_order_list(&self, cmd: SubmitOrderList) -> Result<()>

Submits a list of orders to the execution venue.

fn modify_order(&self, cmd: ModifyOrder) -> Result<()>

Modifies an existing order.

fn batch_modify_orders(&self, cmd: BatchModifyOrders) -> Result<()>

Modifies a batch of orders.

fn cancel_order(&self, _cmd: CancelOrder) -> Result<()>

Cancels a specific order.

fn cancel_all_orders(&self, _cmd: CancelAllOrders) -> Result<()>

Cancels all orders.

fn batch_cancel_orders(&self, _cmd: BatchCancelOrders) -> Result<()>

Cancels a batch of orders.

fn query_account(&self, cmd: QueryAccount) -> Result<()>

Queries the status of an account.

fn query_order(&self, _cmd: QueryOrder) -> Result<()>

Queries the status of an order.

fn on_instrument(&mut self, instrument: InstrumentAny)

Handles an instrument update received via the message bus.

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Connects the client to the execution venue.

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Disconnects the client from the execution venue.

fn generate_order_status_report<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReport, ) -> Pin<Box<dyn Future<Output = Result<Option<OrderStatusReport>, Error>> + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Generates a single order status report.

fn generate_order_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<OrderStatusReport>, Error>> + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Generates multiple order status reports.

fn generate_fill_reports<'life0, 'async_trait>( &'life0 self, cmd: GenerateFillReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<FillReport>, Error>> + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Generates fill reports based on execution results.

fn generate_position_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GeneratePositionStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<PositionStatusReport>, Error>> + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Generates position status reports.

fn generate_mass_status<'life0, 'async_trait>( &'life0 self, lookback_mins: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Option<ExecutionMassStatus>, Error>> + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Generates mass status for executions.

fn register_external_order( &self, _client_order_id: ClientOrderId, _venue_order_id: VenueOrderId, _instrument_id: InstrumentId, _strategy_id: StrategyId, _ts_init: UnixNanos, )

Registers an external order for tracking by the execution client.

fn calculate_commission( &self, instrument: &InstrumentAny, last_qty: Quantity, last_px: Price, liquidity_side: LiquiditySide, ) -> Option<Money>

Calculates the commission for a reconciliation fill.