Struct RegistryConfig 

pub struct RegistryConfig {
    pub broadcast_capacity: usize,
    pub publisher_grace_period: Duration,
    pub idle_stream_timeout: Duration,
    pub max_gop_size: usize,
    pub cleanup_interval: Duration,
    pub max_consecutive_lag_events: u32,
    pub lag_threshold_low: u64,
}

Configuration for the stream registry

Fields

broadcast_capacity: usize

Capacity of the broadcast channel per stream

At 30fps, 128 frames is about 4 seconds of video buffer. If subscribers fall behind more than this, they’ll receive a Lagged error.

publisher_grace_period: Duration

Grace period to keep stream alive after publisher disconnects

If the publisher reconnects within this period, subscribers continue without interruption. This handles brief network hiccups.

idle_stream_timeout: Duration

Timeout for idle streams with no publisher and no subscribers

max_gop_size: usize

Maximum GOP buffer size in bytes per stream

cleanup_interval: Duration

Interval for running cleanup tasks

max_consecutive_lag_events: u32

Number of lag events before disconnecting a slow subscriber

lag_threshold_low: u64

Lag threshold (frames) below which we continue normally

Implementations

impl RegistryConfig

pub fn new() -> Self

Create a new registry config with default values

pub fn broadcast_capacity(self, capacity: usize) -> Self

Set the broadcast channel capacity

pub fn publisher_grace_period(self, duration: Duration) -> Self

Set the publisher grace period

pub fn idle_stream_timeout(self, duration: Duration) -> Self

Set the idle stream timeout

pub fn max_gop_size(self, size: usize) -> Self

Set the maximum GOP buffer size

Trait Implementations

impl Clone for RegistryConfig

fn clone(&self) -> RegistryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RegistryConfig

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

Formats the value using the given formatter.

impl Default for RegistryConfig

fn default() -> Self

Returns the “default value” for a type.