Struct IoStats 

pub struct IoStats(/* private fields */);

A shareable, cloneable handle to a set of cumulative I/O counters.

All clones share the same underlying counters. This serves two purposes:

1. It backs each ScanScheduler’s own running totals.
2. It can be attached to an individual FileScheduler (via FileScheduler::with_io_stats) as a secondary sink, so a caller can measure the exact bytes/IOPS performed through that file handle for a bounded scope (e.g. a single query) without disturbing the scheduler’s global totals. Read the result back with IoStats::snapshot.

Implementations

impl IoStats

pub fn new() -> Self

pub fn record_request(&self, request: &[Range<u64>])

Record a single completed request. request holds the byte ranges as actually submitted to storage (post coalescing/splitting), so the counts reflect physical I/O.

pub fn snapshot(&self) -> ScanStats

Take an immutable snapshot of the current cumulative counters.

pub fn recorder(&self) -> Arc<dyn IoStatsRecorder>

Return this handle as a type-erased IoStatsRecorder, suitable for attaching to a file reader (e.g. FileReader::with_io_stats). The returned recorder shares the same underlying counters as self.

pub fn add_scan_stats(&self, stats: &ScanStats)

Add a snapshot of already-aggregated statistics into this sink. Used to fold in I/O measured on a separate scheduler (e.g. the one-time reads performed while opening an index).

Trait Implementations

impl Clone for IoStats

fn clone(&self) -> IoStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IoStats

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

Formats the value using the given formatter.

impl Default for IoStats

fn default() -> Self

Returns the “default value” for a type.