Struct WorkerMetrics 

pub struct WorkerMetrics {
    pub initialization_time: Duration,
    pub average_message_latency: Duration,
    pub max_message_latency: Duration,
    pub messages_processed: u64,
    pub messages_dropped: u64,
    pub memory_start: u64,
    pub memory_end: u64,
    pub error_recoveries: u32,
}

Worker performance metrics

Fields

initialization_time: Duration

Time to initialize worker

average_message_latency: Duration

Average message round-trip latency

max_message_latency: Duration

Maximum message latency observed

messages_processed: u64

Total messages processed

messages_dropped: u64

Messages dropped (if any)

memory_start: u64

Memory at start (bytes)

memory_end: u64

Memory at end (bytes)

error_recoveries: u32

Number of error recoveries

Implementations

impl WorkerMetrics

pub fn has_memory_leak(&self) -> bool

Check if there’s a memory leak (>10% growth)

pub fn memory_growth(&self) -> i64

Get memory growth in bytes

Trait Implementations

impl Clone for WorkerMetrics

fn clone(&self) -> WorkerMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerMetrics

fn default() -> WorkerMetrics

Returns the “default value” for a type.