offline_protocol::telemetry::metrics_snapshot

Struct MetricsFrame

pub struct MetricsFrame {
    pub timestamp_ms: i64,
    pub transports: Vec<(TransportType, TransportMetrics)>,
    pub retry_queue: RetryQueueStats,
    pub dedup: DeduplicatorStats,
    pub ack_pending: usize,
    pub neighbor_count: usize,
    pub is_local_relay: bool,
    pub current_transport: Option<TransportType>,
}

Expand description

Snapshot of every push-able counter the SDK exposes.

The inner collections are pre-materialized at aggregation time so the sink receives owned-but-cheap data — no iteration, no locking on the sink side.

Fields§

§timestamp_ms: i64

Emission timestamp (milliseconds since Unix epoch).

§transports: Vec<(TransportType, TransportMetrics)>

Per-transport metrics for every transport currently reporting TransportStatus::Available.

§retry_queue: RetryQueueStats

Retry-queue statistics (pending + ready + per-priority counts).

§dedup: DeduplicatorStats

Deduplicator statistics (tracked ids, capacity, mode).

§ack_pending: usize

Number of messages awaiting acknowledgement.

§neighbor_count: usize

Number of currently known neighbors.

§is_local_relay: bool

Whether this node is currently acting as a relay on the mesh.

Reflects RelayManager::current_role() at the moment of emission. Named deliberately — this is a local-role flag, not a peer count. A future record with an explicit per-peer-relay registry may add a relay_peer_count field alongside; those semantics are orthogonal.

§current_transport: Option<TransportType>

Currently selected transport, if any.

Struct MetricsFrame Copy item path

Fields§

Implementations§

impl MetricsFrame

pub const NAME: &'static str = "protocol.metrics.snapshot"

pub fn telemetry_name(&self) -> &'static str

Trait Implementations§

impl Clone for MetricsFrame

fn clone(&self) -> MetricsFrame

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

impl Debug for MetricsFrame

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

Auto Trait Implementations§

impl Freeze for MetricsFrame

impl RefUnwindSafe for MetricsFrame

impl Send for MetricsFrame

impl Sync for MetricsFrame

impl Unpin for MetricsFrame

impl UnsafeUnpin for MetricsFrame

impl UnwindSafe for MetricsFrame

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> Classify for T

type Classified = T

fn classify(self) -> T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> Declassify for T

type Declassified = T

fn declassify(self) -> T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self> ⓘ

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for Twhere 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>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct MetricsFrame

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

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

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

impl<T> CloneToUninit for T
where T: Clone,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<T> ToOwned for T
where T: Clone,

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

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

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

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