Struct RecorderSlot 

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

A connector’s slot for the recorder the pipeline installs (#638 / #704).

Connectors keep one of these in their struct and forward set_roundtrip_recorder to install; every call site then does self.roundtrips.record("get") without checking whether a pipeline installed anything. First install wins — the pipeline installs exactly once per run, and a re-used connector instance keeps the labels it is already counting under.

Implementations

impl RecorderSlot

pub const fn new() -> Self

pub fn install(&self, recorder: Arc<RoundtripRecorder>)

Install the pipeline’s recorder (no-op when one is already installed).

pub fn recorder(&self) -> Option<Arc<RoundtripRecorder>>

The installed recorder, for handing to a helper that performs I/O on the connector’s behalf.

pub fn record(&self, op: &'static str)

Count one round trip when a recorder is installed.

pub fn record_timed(&self, op: &'static str, elapsed: Duration)

Count one timed round trip when a recorder is installed.

pub fn replication_key_missing(&self, n: u64)

Count records missing their replication key when a recorder is installed.

pub fn throttled(&self)

Count one rate-limit response when a recorder is installed.

pub fn retry(&self, class: RetryClass)

Count one retry of class when a recorder is installed.

pub fn throttle_wait_timer(&self) -> ThrottleWait

Start timing a rate-limit sleep (ThrottleWait).

pub fn signal(&self, kind: &'static str, unit: &'static str, quantity: f64)

Report a backend-measured usage figure when a recorder is installed.

Trait Implementations

impl Debug for RecorderSlot

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

Formats the value using the given formatter.

impl Default for RecorderSlot

fn default() -> Self

Returns the “default value” for a type.