Struct Consumer 

pub struct Consumer { /* private fields */ }

Reads one published stats broadcast (a <prefix>/node/<node> announce), yielding typed frames per track.

Subscribe to the traffic and session tracks you care about with Self::traffic / Self::sessions; a track that the producer never created (e.g. a named tier that saw no traffic) fails to subscribe or ends immediately, so callers typically subscribe the tiers they know exist.

Implementations

impl Consumer

pub fn new(broadcast: Consumer, config: ConsumerConfig) -> Self

Wrap a stats broadcast. The broadcast is whatever the announce at a stats path resolved to; parse the path with crate::parse_node_path.

pub async fn traffic(&self, tier: &Tier, role: Role) -> Result<TrafficConsumer>

Subscribe to the traffic track for (tier, role), awaiting the subscription handshake.

pub async fn sessions(&self, tier: &Tier) -> Result<SessionsConsumer>

Subscribe to the sessions track for tier, awaiting the subscription handshake.