Struct ThroughputTracker 

pub struct ThroughputTracker { /* private fields */ }

Throughput tracker for monitoring performance over time.

Provides time-windowed throughput calculations for records, bytes, and transactions. Maintains sliding windows of recent performance data for real-time monitoring and trend analysis.

Examples

use crate::backend::native::v2::wal::metrics::aggregation::ThroughputTracker;

let mut tracker = ThroughputTracker::new();
tracker.record_write_operation(1024);
tracker.record_transaction();

let (records, bytes, tx) = tracker.get_current_throughput();
assert!(records > 0.0);

Implementations

impl ThroughputTracker

pub fn new() -> Self

Create new throughput tracker with default settings.

Initializes with a 60-second time window and maximum of 300 samples (5 minutes of historical data) for comprehensive trend analysis.

Returns

A new ThroughputTracker instance ready for operation tracking

pub fn record_write_operation(&mut self, bytes: usize)

Record a write operation.

Adds a write operation to the throughput tracking, updating both record and byte throughput metrics.

Arguments

• bytes - Number of bytes written in the operation

pub fn record_read_operation(&mut self, bytes: usize)

Record a read operation.

Adds a read operation to the throughput tracking for performance monitoring and capacity planning.

Arguments

• bytes - Number of bytes read in the operation

pub fn record_transaction(&mut self)

Record a transaction.

Tracks transaction completion rates for monitoring transaction throughput and system performance under load.

pub fn get_current_throughput(&self) -> (f64, f64, f64)

Get current throughput metrics.

Calculates current throughput rates based on the accumulated data within the configured time window.

Returns

Tuple containing (records_per_sec, bytes_per_sec, transactions_per_sec)

pub fn get_peak_throughput(&self) -> (f64, f64, f64)

Get peak throughput metrics.

Calculates the maximum observed throughput rates for capacity planning and performance benchmarking.

Returns

Tuple containing (peak_records_per_sec, peak_bytes_per_sec, peak_transactions_per_sec)

pub fn reset(&mut self)

Reset throughput tracker.

Clears all accumulated throughput data and resets the tracker to its initial state for fresh measurements.

Trait Implementations

impl Clone for ThroughputTracker

fn clone(&self) -> ThroughputTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThroughputTracker

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

Formats the value using the given formatter.

impl Default for ThroughputTracker

fn default() -> Self

Returns the “default value” for a type.