Struct Traffic 

#[non_exhaustive]
pub struct Traffic {
    pub announced: u64,
    pub announced_closed: u64,
    pub announced_bytes: u64,
    pub broadcasts: u64,
    pub broadcasts_closed: u64,
    pub subscriptions: u64,
    pub subscriptions_closed: u64,
    pub fetches: u64,
    pub bytes: u64,
    pub frames: u64,
    pub groups: u64,
    pub datagrams: u64,
}

A cumulative traffic counter readout for one slice (a broadcast on a (tier, role), or any sum of such slices).

Every counter is cumulative, so a rate is delta / delta_t and a live count is open - closed. This is also the wire shape of one entry on a published stats track (the moq-stats crate serializes maps of these), so it derives both serde directions; unknown fields from a newer publisher are ignored and missing fields from an older one default to zero.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

announced: u64

Cumulative broadcast announce events on this slice.

announced_closed: u64

Cumulative broadcast unannounce events on this slice.

announced_bytes: u64

Cumulative announce-control bytes: the broadcast name length summed over each announce and unannounce. Distinct from bytes (payload).

broadcasts: u64

Per-(broadcast, session) subscription sentinel opens: the first active subscription a session holds on a broadcast.

broadcasts_closed: u64

Sentinel closes: the session’s last subscription to the broadcast ended.

subscriptions: u64

Cumulative track-level subscriptions opened.

subscriptions_closed: u64

Cumulative track-level subscriptions closed.

fetches: u64

Cumulative one-shot group fetches requested. Counted once per coalesced fetch when the fetch is issued, so one that resolves to NotFound still counts. Separate from subscriptions and the viewer refcount. Fetched payload still flows into bytes/frames/groups.

bytes: u64

Cumulative payload bytes.

frames: u64

Cumulative frames delivered.

groups: u64

Cumulative groups delivered.

datagrams: u64

Cumulative single-frame groups delivered over an unreliable QUIC datagram. A subset of groups: each one also counts there and its payload in frames / bytes.

Implementations

impl Traffic

pub fn add(&mut self, other: Traffic)

Fold another readout into this one, counter by counter.

pub fn is_announced(&self) -> bool

True while the broadcast is announced (an announce guard is open).

pub fn active_broadcasts(&self) -> u64

Distinct sessions currently subscribed (viewers on the egress side).

pub fn active_subscriptions(&self) -> u64

Track subscriptions currently open.

pub fn total_bytes(&self) -> u64

All bytes attributable to this slice: payload plus announce overhead. Both inputs are monotonic, so the sum regresses only when the entry was garbage collected and re-created.

pub fn is_idle(&self) -> bool

True once every open counter equals its closed counterpart: no guard is held, so no more traffic can flow until a new open.

Trait Implementations

impl Clone for Traffic

fn clone(&self) -> Traffic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Traffic

impl Debug for Traffic

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

Formats the value using the given formatter.

impl Default for Traffic

fn default() -> Traffic

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Traffic

where Traffic: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Traffic

impl PartialEq for Traffic

fn eq(&self, other: &Traffic) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Traffic

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Traffic