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(&self, state: &PipelineState) -> Self

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( &self, state: &PipelineState, backend: &dyn TelemetryBackend, ) -> Self

Record a snapshot and send to telemetry backend.

Trait Implementations

impl Clone for MemoryMetricsCollector

fn clone(&self) -> MemoryMetricsCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryMetricsCollector

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

Formats the value using the given formatter.