Struct MemoryMonitor 

pub struct MemoryMonitor {
    pub active_timers: Arc<AtomicU64>,
    pub active_tasks: Arc<AtomicU64>,
    pub channel_depth: Arc<AtomicU64>,
    pub messages_processed: Arc<AtomicU64>,
    pub peak_memory_bytes: Arc<AtomicU64>,
}

Memory usage statistics and monitoring.

Fields

active_timers: Arc<AtomicU64>

Number of active timers

active_tasks: Arc<AtomicU64>

Number of spawned tasks

channel_depth: Arc<AtomicU64>

Current channel buffer depth

messages_processed: Arc<AtomicU64>

Total messages processed

peak_memory_bytes: Arc<AtomicU64>

Peak memory usage (if available)

Implementations

impl MemoryMonitor

pub fn new() -> Self

Create a new memory monitor.

pub fn timer_added(&self)

Increment the timer count.

pub fn timer_removed(&self)

Decrement the timer count.

pub fn get_active_timers(&self) -> u64

Get the current number of active timers.

pub fn task_spawned(&self)

Increment the task count.

pub fn task_completed(&self)

Decrement the task count.

pub fn get_active_tasks(&self) -> u64

Get the current number of active tasks.

pub fn set_channel_depth(&self, depth: u64)

Update the channel depth.

pub fn get_channel_depth(&self) -> u64

Get the current channel depth.

pub fn message_processed(&self)

Increment the message count.

pub fn get_messages_processed(&self) -> u64

Get the total number of messages processed.

pub fn update_peak_memory(&self, bytes: u64)

Update peak memory usage (if tracking is enabled).

pub fn get_peak_memory_bytes(&self) -> u64

Get the peak memory usage.

pub fn snapshot(&self) -> MemorySnapshot

Get a snapshot of all current metrics.

pub fn reset(&self)

Reset all counters to zero.

pub fn check_health(&self) -> MemoryHealth

Check if any metrics indicate potential memory issues.

Trait Implementations

impl Clone for MemoryMonitor

fn clone(&self) -> MemoryMonitor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryMonitor

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

Formats the value using the given formatter.

impl Default for MemoryMonitor

fn default() -> Self

Returns the “default value” for a type.