Struct MonitoringSession 

pub struct MonitoringSession {
    pub name: String,
    pub start_time: Instant,
    pub metrics: Vec<TransformationMetrics>,
    pub config: MonitoringConfig,
}

Pipeline monitoring session

Fields

name: String

Session name

start_time: Instant

Start time

metrics: Vec<TransformationMetrics>

All transformation metrics

config: MonitoringConfig

Session configuration

Implementations

impl MonitoringSession

pub fn new(name: String) -> Self

Create a new monitoring session

pub fn with_config(name: String, config: MonitoringConfig) -> Self

Create a session with custom configuration

pub fn start_transformation( &mut self, name: String, input: &Array2<f64>, ) -> usize

Start tracking a transformation

pub fn complete_transformation( &mut self, index: usize, output: &Array2<f64>, ) -> Result<(), String>

Complete a transformation

pub fn fail_transformation( &mut self, index: usize, error: String, ) -> Result<(), String>

Fail a transformation

pub fn total_duration(&self) -> Duration

Get total session duration

pub fn total_processing_time(&self) -> f64

Get total processing time (sum of all transformations)

pub fn average_throughput(&self) -> Option<f64>

Get average throughput

pub fn successful_count(&self) -> usize

Get successful transformations

pub fn failed_count(&self) -> usize

Get failed transformations

pub fn summary(&self) -> MonitoringSummary

Generate summary report

pub fn print_summary(&self)

Print summary

Trait Implementations

impl Debug for MonitoringSession

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

Formats the value using the given formatter.