Struct RoundtripRecorder 

pub struct RoundtripRecorder { /* private fields */ }

A pre-labelled handle a connector uses to count its own backend calls.

Cheap to clone (the label vec is built once at construction and cloned per call, exactly like the decorators’ base_labels). Held behind an Arc/OnceLock by connectors that opt in; a connector that never calls record emits nothing at all, so instrumentation can land connector by connector without any behaviour change in between.

Implementations

impl RoundtripRecorder

pub fn new( side: RoundtripSide, pipeline: impl Into<SharedString>, row: impl Into<SharedString>, connector: impl Into<SharedString>, ) -> Self

Build a recorder for one connector instance.

pub fn throttle_tally(&self) -> Arc<ThrottleTally>

The rate-limit totals this recorder has observed so far.

pub fn throttled(&self)

Count one rate-limit response (HTTP 429, a RateLimited error, a backend’s throttling code) — every one received, whether or not it is retried. Emits faucet_source_throttled_total.

pub fn throttle_wait(&self, slept: Duration)

Record time actually slept because of a rate limit. Pass the measured sleep, never the server’s Retry-After value; ThrottleWait measures it for you, including a sleep cut short by cancellation.

pub fn retry(&self, class: RetryClass)

Count one retry the connector is about to make, by class. Emits faucet_source_retries_total{class}.

pub fn with_meter(self, meter: Arc<UsageMeter>) -> Self

Also tally into a run’s usage meter (#704).

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

Report a backend-measured usage figure (#704) — BigQuery’s bytes billed for a job, the payload size of a streaming insert, a warehouse’s credits. Emitted as faucet_cost_signals_total{pipeline,row,connector,kind,unit} (the quantity rounded to a whole unit) and, when a meter is attached, kept verbatim for the run’s usage record. kind and unit are a closed set per connector, documented in its README.

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

Count one round trip to the backend.

op must come from the connector’s own closed set — never a URL, query, status code, or host, which would make the series unbounded. A retried call is a real round trip and must be counted again.

pub fn replication_key_missing(&self, n: u64)

Count records whose incremental replication key was missing or null (#747). Emits faucet_source_replication_key_missing_total.

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

Count one round trip and record how long it took.

Trait Implementations

impl Clone for RoundtripRecorder

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoundtripRecorder

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

Formats the value using the given formatter.