Expand description
The aggregating half: fold a group’s per-node stats broadcasts into one view.
A single-broadcast Consumer reads one
<prefix>/<group>/node/<node> broadcast. This reader watches an origin’s
announce stream for every node broadcast in a group and folds their
cumulative counters into one merged frame per (tier, role), so a downstream
sees a project’s whole live traffic as if it came from a single node.
Structs§
- Config
- Configuration for an
Consumer. Construct withConfig::newand chain thewith_*setters. - Consumer
- Folds a group’s per-node stats broadcasts into one merged view.
- Sessions
Consumer - A merged reader over one sessions track across every node in the group; see
TrafficConsumer. - Traffic
Consumer - A merged reader over one traffic track across every node in the group. Yields
the latest merged
TrafficFrame; a slow reader collapses intermediate frames, which is safe because the counters are cumulative.