Struct MockTradeSyncer 

pub struct MockTradeSyncer { /* private fields */ }

Mock trade syncer for fill-based strategies.

Implementations

impl MockTradeSyncer

pub fn new() -> Self

Create a mock trade syncer.

pub async fn set_should_fail(&self, should_fail: bool)

Configure whether sync calls should fail.

pub async fn set_simulated_pnl(&self, pnl: f64)

Set the PnL returned by successful sync calls.

pub async fn sync_calls(&self) -> Vec<TradeSyncCall>

Return all recorded trade sync calls.

pub async fn total_fills_synced(&self) -> usize

Count fills across all recorded trade sync calls.

pub async fn assert_all_fills_synced(&self, expected_fills: &[Fill])

Assert that the expected number of fills was synced.

pub async fn sync( &mut self, fills: Vec<Fill>, current_price: Option<Decimal>, stop_bot: bool, stop_reason: &str, ) -> Result<SyncResult, SyncError>

Record a trade sync call and return the configured mock result.

Trait Implementations

impl Default for MockTradeSyncer

fn default() -> Self

Returns the “default value” for a type.

impl TradeSync for MockTradeSyncer

fn add_fill(&mut self, _fill: Fill)

Add a fill to the pending queue

fn should_sync(&self) -> bool

Check if it’s time to sync based on interval

fn pending_count(&self) -> usize

Get count of pending fills

fn last_pnl(&self) -> Option<f64>

Get last known PnL

fn sync<'life0, 'life1, 'async_trait>( &'life0 mut self, current_price: Option<Decimal>, stop_bot: bool, stop_reason: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<TradeSyncResult, SyncError>> + Send + 'async_trait>>

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

Sync pending fills to upstream

fn shutdown_sync<'life0, 'life1, 'async_trait>( &'life0 mut self, current_price: Option<Decimal>, stop_reason: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<TradeSyncResult, SyncError>> + Send + 'async_trait>>

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

Perform final sync on shutdown

fn set_metrics_snapshot( &mut self, _snapshot: Option<PerformanceMetricsSnapshot>, )

Set the latest performance metrics snapshot to include in sync metadata.