Struct UsageMeter 

pub struct UsageMeter { /* private fields */ }

The live, thread-safe counters of one run. Cheap to share (Arc).

Implementations

impl UsageMeter

pub fn new() -> Self

pub fn add_read(&self, records: u64, bytes: u64)

Count a page the source yielded.

pub fn add_written(&self, records: u64, bytes: u64)

Count a page the sink accepted.

pub fn add_roundtrip(&self, side: UsageSide, op: &'static str)

Count one backend round trip.

pub fn add_signal(&self, signal: CostSignal)

Record a backend-reported usage figure.

pub fn add_throttled(&self)

Count one rate-limit response the source received.

pub fn add_throttle_wait(&self, slept: Duration)

Add time the source actually slept on a rate limit.

pub fn add_source_retry(&self, class: &'static str)

Count one source-side retry of class.

pub fn records_written(&self) -> u64

Records the sink accepted so far (what a max_records budget checks).

pub fn bytes_written(&self) -> u64

Estimated bytes the sink accepted so far (what a max_bytes budget checks).

pub fn snapshot(&self) -> UsageSnapshot

Freeze the counters.

Trait Implementations

impl Debug for UsageMeter

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

Formats the value using the given formatter.

impl Default for UsageMeter

fn default() -> Self

Returns the “default value” for a type.