Struct ya_sb_router::RouterConfig

#[non_exhaustive]
pub struct RouterConfig {
    pub ping_interval: Duration,
    pub ping_timeout: Duration,
    pub broadcast_backlog: usize,
    pub forward_timeout: Duration,
    pub high_buffer_mark: usize,
    pub gc_interval: Option<Duration>,
}

Message router configuration.

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.

ping_interval: Duration

How often to check for incoming traffic for a connection.

ping_timeout: Duration

After what time a connection without incoming traffic is considered dead.

broadcast_backlog: usize

How many messages per topic should be store for lagging receivers.

forward_timeout: Duration

How much time to hold incoming data while waiting for a recipient.

high_buffer_mark: usize

How many messages can wait to be sent before server starts holding back senders.

gc_interval: Option<Duration>

How often to scan for unused resources.

Implementations

impl RouterConfig

pub fn from_env() -> Self

New Configuration from environment variables.

pub fn gc_interval_secs(&mut self, gc_secs: u64) -> &mut Self

Sets the number of seconds to scan for unused resources.

Trait Implementations

impl Default for RouterConfig

fn default() -> Self

Returns the “default value” for a type.