Struct MetricAggregator 

pub struct MetricAggregator { /* private fields */ }

Aggregates per-frame metrics and computes derived statistics.

Implementations

impl MetricAggregator

pub fn new(session_id: u64, start_time_ms: i64, source_fps: f32) -> Self

Creates a new aggregator for session_id starting at start_time_ms.

pub fn counters(&self) -> Arc<TranscodeMetrics>

Returns a shared reference to the atomic counters.

pub fn update_frame(&mut self, metric: FrameMetric)

Records a new frame metric, updates ring buffer and atomic counters.

pub fn compute_rate(&self, current_time_ms: i64) -> EncodingRate

Computes current EncodingRate given the current wall-clock time.

pub fn rolling_avg_psnr(&self, window: usize) -> f32

Computes the rolling average PSNR over the last window frame metrics.

Clamps window to the available ring-buffer size.

pub fn export_csv(&self) -> String

Exports all per-frame metrics in CSV format.

Columns: frame_number,frame_type,encode_time_us,output_bits,psnr

pub fn to_prometheus(&self, session_id: u64) -> String

Exports current session metrics in Prometheus text exposition format.

All metric names are prefixed oximedia_transcode_.

pub fn session(&self) -> &SessionMetrics

Returns a reference to the session metrics.

Trait Implementations

impl Debug for MetricAggregator

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

Formats the value using the given formatter.