Struct MemoryMetricsCollector 

pub struct MemoryMetricsCollector { /* private fields */ }

Memory metrics collector for pipeline execution.

Implementations

impl MemoryMetricsCollector

pub const fn new(snapshot_interval: u32) -> Self

Create a new metrics collector.

Arguments

• snapshot_interval - Take snapshot every N iterations (0 = disabled)

pub fn maybe_record(&mut self, state: &PipelineState)

Record a snapshot if at snapshot interval.

pub fn snapshots(&self) -> &[MemorySnapshot]

Get all recorded snapshots.

pub fn export_json(&self) -> Result<String>

Export snapshots as JSON for external analysis.

Errors

Returns error if the operation fails.

pub fn record_and_emit( &mut self, state: &PipelineState, backend: &mut dyn TelemetryBackend, )

Record a snapshot and send to telemetry backend.

Trait Implementations

impl Debug for MemoryMetricsCollector

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

Formats the value using the given formatter.