Struct PerformanceMetrics 

pub struct PerformanceMetrics { /* private fields */ }

Performance metrics collector

Implementations

impl PerformanceMetrics

pub fn new() -> Self

Create a new performance metrics collector

pub async fn record_latency(&self, topic: &str, latency_us: u64)

Record message latency

pub async fn record_message(&self, topic: &str, size_bytes: usize)

Record message throughput

pub async fn start_timer(&self, name: &str) -> TimerGuard

Start timing a code block

pub async fn record_execution(&self, name: &str, duration: Duration)

Record execution time

pub async fn record_memory(&self, allocated_bytes: usize, freed_bytes: usize)

Record memory usage

pub async fn get_latency_stats(&self, topic: &str) -> Option<LatencyStats>

Get latency statistics for a topic

pub async fn get_throughput_stats(&self, topic: &str) -> Option<ThroughputStats>

Get throughput statistics for a topic

pub async fn get_execution_stats(&self, name: &str) -> Option<ExecutionStats>

Get execution statistics for a named block

pub async fn get_memory_stats(&self) -> MemoryStats

Get memory statistics

pub async fn get_report(&self) -> PerformanceReport

Get all metrics as a report

pub async fn reset(&self)

Reset all metrics

Trait Implementations

impl Clone for PerformanceMetrics

fn clone(&self) -> PerformanceMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PerformanceMetrics

fn default() -> Self

Returns the “default value” for a type.