Struct ProducerConfig 

#[non_exhaustive]
pub struct ProducerConfig {
    pub origin: Option<Producer>,
    pub prefix: PathOwned,
    pub node: Option<PathOwned>,
    pub interval: Duration,
    pub depth: usize,
}

Settings for a Producer. Construct with ProducerConfig::new and chain the with_* setters (e.g. ProducerConfig::new().with_origin(origin).with_prefix(".foo")), then hand it to Producer::new.

With no origin set the resulting producer is a no-op: its registry is disabled (bumps are dropped) and no task spawns. Call ProducerConfig::with_origin to publish.

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.

origin: Option<Producer>

Origin the stats broadcasts are created on. When None, Producer::new spawns no task and publishes nothing.

prefix: PathOwned

Top-level path stats are published under (default .stats). The full advertised path is <prefix>/node/<node> (or <prefix>/node when node is unset). Also the registry’s exclude prefix, so serving a stats broadcast doesn’t generate more stats.

node: Option<PathOwned>

Node suffix that disambiguates broadcasts from different relays sharing a cluster origin. Set this on every node in multi-relay deployments. May be multi-segment (e.g. sjc/1, sjc/2) so a region with multiple hosts can nest under a shared region key. An empty path is treated as unset. Default none.

interval: Duration

How long the publish task waits between drains. Default 1s.

depth: usize

How many leading broadcast-path segments to use as a grouping key.

Default 0 publishes one <prefix>/node/<node> broadcast carrying every path. 1 publishes one broadcast per first segment at <prefix>/<group>/node/<node>, and larger values include more leading segments. Group broadcasts are announced while their group has live traffic; at depth 0, the single broadcast stays announced for the producer’s life.

Implementations

impl ProducerConfig

pub fn new() -> Self

A config with default settings: no origin (no-op), .stats prefix, 1s interval, and no node suffix. Call Self::with_origin to actually publish.

pub fn with_origin(self, origin: impl Into<Option<Producer>>) -> Self

Set the origin to publish the stats broadcast on. Without this the producer is a no-op.

pub fn with_prefix(self, prefix: impl Into<PathOwned>) -> Self

Override the top-level prefix (default .stats).

pub fn with_interval(self, interval: Duration) -> Self

Override the publish interval (default 1s).

pub fn with_node(self, node: impl Into<Option<PathOwned>>) -> Self

Set the node suffix (default none). An empty path is treated as unset.

pub fn with_depth(self, depth: usize) -> Self

Set the grouping depth (default 0, a single broadcast). See Self::depth.

Trait Implementations

impl Clone for ProducerConfig

fn clone(&self) -> ProducerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ProducerConfig

fn default() -> Self

Returns the “default value” for a type.