Struct OrderReaperService 

pub struct OrderReaperService { /* private fields */ }

Supervised service that reconciles tracked orders against the exchange and cancels any that outlive the configured TTL.

Spawned by Bot::run_until_shutdown only when order tracking is wired and the adapter advertises Capability::OrderTracking.

Implementations

impl OrderReaperService

pub fn cancelled(&self) -> u64

Total resting orders cancelled for exceeding the TTL.

pub fn reconciled(&self) -> u64

Total tracked orders dropped because the exchange no longer lists them (filled or cancelled out-of-band).

pub fn sweeps(&self) -> u64

Total reconcile/reap sweeps performed.

Trait Implementations

impl TradingService for OrderReaperService

fn name(&self) -> &str

Unique service name for logs, metrics, and supervisor identification.

fn restart_policy(&self) -> RestartPolicy

When should the supervisor restart this service on exit?

fn run<'life0, 'async_trait>( &'life0 self, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Main execution loop. Must honour the cancellation token.