Metrics

twg_sink_zerobus::metrics

Struct Metrics

pub struct Metrics {
    pub bursts: AtomicU64,
    pub burst_items: AtomicU64,
    pub pending: AtomicI64,
    pub delivery_latency_us: AtomicU64,
    pub deliveries: AtomicU64,
    pub ack_lane_retry: AtomicU64,
    pub ack_lane_poisoned: AtomicU64,
    pub stream_rebuilds: AtomicU64,
    pub concurrency_rejects: AtomicU64,
    pub type_reconcile: AtomicU64,
    pub type_reconcile_unreconcilable: AtomicU64,
}

Expand description

Atomic counters and gauges for one sink.

Fields§

§bursts: AtomicU64

Number of ack-lane bursts processed.

§burst_items: AtomicU64

Total items across all bursts (÷ bursts = coalesce ratio; ≫1 = pipelining).

§pending: AtomicI64

submitted − delivered; climbs under load.

§delivery_latency_us: AtomicU64

Sum of delivery latencies (µs), emitted from the ack lane off the hot path.

§deliveries: AtomicU64

Count of delivery-latency samples.

§ack_lane_retry: AtomicU64

Transient ack retries (environmental slow-ack).

§ack_lane_poisoned: AtomicU64

Ack lanes that died (self-inflicted poison) — the cause signal the runbook branches on, distinct from the shared slow-ack symptom.

§stream_rebuilds: AtomicU64

Stream rebuilds (churn visibility — the predecessor’s blind spot).

§concurrency_rejects: AtomicU64

Concurrency-limit rejects (the too-many-streams signal).

§type_reconcile: AtomicU64

Emit-time type reconciliations performed (auto-project / passthrough).

§type_reconcile_unreconcilable: AtomicU64

Unreconcilable write-boundary mismatches surfaced loudly (column named).

Implementations§

impl Metrics

pub fn record_burst(&self, items: usize, latency_us: u64)

Record that a burst of items was delivered with latency_us total.

pub fn coalesce_ratio(&self) -> f64

Mean burst size — the “are we pipelining?” signal (≫1 under load). The counts are approximate telemetry, so the f64 conversion’s precision loss at astronomically large totals is immaterial.

Trait Implementations§

impl Debug for Metrics

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

Formats the value using the given formatter. Read more

impl Default for Metrics

fn default() -> Metrics

Returns the “default value” for a type. Read more

Auto Trait Implementations§

impl !Freeze for Metrics

impl RefUnwindSafe for Metrics

impl Send for Metrics

impl Sync for Metrics

impl Unpin for Metrics

impl UnwindSafe for Metrics

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in [Layered].

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,