Struct TradeSyncer 

pub struct TradeSyncer { /* private fields */ }

Trade syncer - handles syncing fills to upstream API

Implementations

impl TradeSyncer

pub fn new(config: TradeSyncerConfig) -> Result<Self, SyncError>

Create a new trade syncer with the given configuration

pub fn add_fill(&mut self, fill: Fill)

Add a fill to the pending queue (will be synced on next sync call)

pub fn should_sync(&self) -> bool

Check if it’s time to sync (based on interval)

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

Get the last known PnL

pub fn pending_count(&self) -> usize

Get the number of pending fills

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

Set the latest performance metrics snapshot for sync metadata.

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

Sync pending fills to upstream API

Returns the PnL from the upstream API on success

pub async fn shutdown_sync( &mut self, current_price: Option<Decimal>, stop_reason: &str, ) -> Result<SyncResult, SyncError>

Perform final sync on shutdown (with stop_bot=true)

Trait Implementations

impl TradeSync for TradeSyncer

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 set_metrics_snapshot(&mut self, snapshot: Option<PerformanceMetricsSnapshot>)

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

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