rlt 0.5.0

A universal load testing library for Rust, with real-time TUI support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Statistics tracking for benchmark iterations.
//!
//! This module provides data structures for collecting and aggregating benchmark
//! statistics across iterations. It supports both cumulative totals and rolling
//! window statistics for real-time monitoring.
//!
//! # Key Types
//!
//! - [`Counter`] - Tracks basic metrics: iterations, items, bytes, and duration.
//! - [`IterStats`] - Aggregates iteration statistics with per-status breakdowns.
//! - [`RotateWindowGroup`] - Manages multiple rolling windows at configurable time scales.
//! - [`RotateDiffWindow`] - Provides rate calculations over sliding windows.

mod counter;
mod window;

pub use counter::Counter;
pub use window::{RotateDiffWindow, RotateWindowGroup};

use std::collections::HashMap;

use crate::{report::IterReport, status::Status};

/// Aggregated statistics for benchmark iterations.
///
/// This structure collects statistics across multiple iterations, providing both
/// a cumulative total and per-status breakdowns. It's used internally by the
/// benchmark framework to track progress and generate reports.
///
/// # Fields
///
/// - `counter` - Cumulative totals across all iterations.
/// - `details` - Per-status breakdown of counters (e.g., separate counts for
///   successful vs failed iterations).
#[derive(Clone, Debug)]
pub struct IterStats {
    /// Cumulative totals across all iterations.
    pub counter: Counter,
    /// Per-status breakdown of counters.
    pub details: HashMap<Status, Counter>,
}

impl IterStats {
    pub fn new() -> Self {
        Self { counter: Counter::default(), details: HashMap::new() }
    }

    pub fn append(&mut self, stats: &IterReport) {
        self.counter.append(stats);
        let counter = self.details.entry(stats.status).or_default();
        counter.append(stats);
    }
}

impl Default for IterStats {
    fn default() -> Self {
        Self::new()
    }
}