Struct ExecutionService 

pub struct ExecutionService { /* private fields */ }

Per-brain execution loop with full risk gating + order placement.

Implementations

impl ExecutionService

pub fn events_processed(&self) -> u64

Total events the brain has been called with.

pub fn events_dropped(&self) -> u64

Total events dropped by the broadcast bus due to slow consumption.

pub fn orders_placed(&self) -> u64

Total orders successfully passed to the exchange.

pub fn orders_blocked(&self) -> u64

Total decisions blocked by a risk gate or by the sizer returning 0.

Trait Implementations

impl TradingService for ExecutionService

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.