Struct MetricsManager 

pub struct MetricsManager { /* private fields */ }

高性能指标管理器

Implementations

impl MetricsManager

pub fn new(enable_metrics: bool, stream_name: String) -> Self

创建新的指标管理器

pub fn record_process(&self, event_type: EventType)

记录处理次数（非阻塞）

pub fn record_events( &self, event_type: EventType, count: u64, processing_time_us: f64, )

记录事件处理（非阻塞）

pub fn log_slow_processing(&self, processing_time_us: f64, event_count: usize)

记录慢处理操作

pub fn get_uptime(&self) -> Duration

获取运行时长

pub fn get_event_metrics(&self, event_type: EventType) -> EventMetricsSnapshot

获取事件指标

pub fn get_processing_stats(&self) -> ProcessingTimeStats

获取处理时间统计

pub fn get_dropped_events_count(&self) -> u64

获取丢弃事件计数

pub fn print_metrics(&self)

打印性能指标（非阻塞）

pub async fn start_auto_monitoring(&self) -> Option<JoinHandle<()>>

启动自动性能监控任务

pub fn new_with_metrics( _metrics: Arc<RwLock<PerformanceMetrics>>, enable_metrics: bool, stream_name: String, ) -> Self

兼容性构造函数

pub fn get_metrics(&self) -> PerformanceMetrics

获取完整的性能指标（兼容性方法）

pub fn add_tx_process_count(&self)

兼容性方法 - 添加交易处理计数

pub fn add_account_process_count(&self)

兼容性方法 - 添加账户处理计数

pub fn add_block_meta_process_count(&self)

兼容性方法 - 添加区块元数据处理计数

pub fn update_metrics( &self, event_type: MetricsEventType, events_processed: u64, processing_time_us: f64, )

兼容性方法 - 更新指标

pub fn increment_dropped_events(&self)

增加丢弃事件计数

pub fn increment_dropped_events_by(&self, count: u64)

批量增加丢弃事件计数

Trait Implementations

impl Clone for MetricsManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.