Struct MonitoringEngine

pub struct MonitoringEngine { /* private fields */ }

High-performance monitoring engine for HFT systems

Implementations

impl MonitoringEngine

pub fn new(config: MonitoringConfig) -> Result<Arc<Self>>

Create a new monitoring engine

pub fn create_collector(&self, name: String) -> Arc<MetricCollector>

Create a new metric collector with a custom name

pub fn register_collector(&self) -> Arc<MetricCollector>

Register a new metric collector with auto-generated name

pub fn collectors(&self) -> Vec<Arc<MetricCollector>>

Get all registered collectors

pub fn collector_count(&self) -> usize

Get the number of registered collectors

pub fn stats(&self) -> EngineStats

Get engine statistics

pub async fn flush(&self) -> Result<()>

Flush all pending metrics to storage

pub fn flush_all(&self) -> Result<()>

Flush all collectors synchronously (convenience method)

pub async fn shutdown(&self) -> Result<()>

Shutdown the monitoring engine