Struct Observability 

pub struct Observability { /* private fields */ }

Public observability facade.

Wraps the lock-free atomic counters (always present) and — in later rollout steps — the feature-gated OpenTelemetry instrument holder. Recording sites in transport, api, and crypto call methods on this struct via an Arc<Observability> borrowed from PhantomListener / PhantomSession.

Implementations

impl Observability

pub fn new(config: ObservabilityConfig) -> Arc<Self>

Construct a new observability handle.

Returns an Arc because the handle is shared between recording sites (in Session, Listener, handshake code paths) and the OTel observable callbacks.

Call once per process. When telemetry-otel is on, this registers observable-instrument callbacks against the global OTel meter; those callbacks are never unregistered (the meter owns them for process life). Constructing many Observability instances would therefore accumulate callbacks. PhantomListener / PhantomSession each hold one shared Arc<Observability> — that is the intended usage.

pub fn config(&self) -> &ObservabilityConfig

Borrow the captured configuration.

pub fn snapshot(&self) -> MetricsSnapshot

Capture a cold-path snapshot of all counters and gauges.

pub fn record_send(&self, bytes: usize, leg: LegType)

pub fn record_recv(&self, bytes: usize, leg: LegType)

pub fn record_encrypt_ns(&self, duration_ns: u64)

pub fn record_decrypt_ns(&self, duration_ns: u64)

pub fn record_rtt_us(&self, rtt_us: u64, path_id: u8)

pub fn session_opened(&self, leg: LegType)

Mark a new session as opened. Updates both the lock-free gauge and the OTel UpDownCounter (when the telemetry-otel feature is on).

pub fn session_closed(&self, leg: LegType)

pub fn stream_opened(&self)

pub fn stream_closed(&self)

pub fn record_handshake_success(&self, duration_ns: u64)

Record a successful handshake completion with its duration (ns).

Transitional API — step 7 introduces a labeled record_handshake that takes (outcome, leg, cipher_suite, version) and writes to an OTel Histogram. Until then, the duration accumulates in atomic sum+count fields surfaced via Self::snapshot.

pub fn record_handshake_failure(&self)

Record a handshake failure. Cause attribution (cookie / signature / transcript / KEM) lands with the labeled API in step 7.

pub fn record_handshake( &self, duration: Duration, outcome: HandshakeOutcome, leg: LegType, cipher: AeadAlgorithm, version: ProtocolVersion, )

Record a handshake outcome and its latency with full OTel attribution. The lock-free atomic counters and the OTel Histogram ({ns}.handshake.duration) are updated together; the histogram’s _count series — sliced by the outcome attribute — is the canonical handshake count, so there is no separate counter.

pub fn record_path_validation( &self, duration: Duration, path_id: u8, outcome: PathValidationOutcome, )

Record a PATH_VALIDATION exchange latency.

pub fn record_resumption(&self, mode: ResumptionMode, accepted: bool)

pub fn record_replay_rejected(&self, reason: ReplayReason)

pub fn record_aead_failure(&self, leg: LegType, algorithm: AeadAlgorithm)

pub fn record_unencrypted_dropped(&self, leg: LegType)

pub fn record_path_migration(&self, from: u8, to: u8)

pub fn record_cookie(&self, outcome: CookieOutcome)

pub fn record_pow(&self, outcome: PowOutcome, difficulty: u8)

pub fn record_early_data(&self, outcome: EarlyDataOutcome)

pub fn record_rekey(&self, direction: Direction)

pub fn record_fallback( &self, from_leg: LegType, to_leg: LegType, reason: FallbackReason, )

Trait Implementations

impl Debug for Observability

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

Formats the value using the given formatter.