Struct RoomWorkerPolicy 

pub struct RoomWorkerPolicy {
    max_local_routers: usize,
    packet_loop_delay_threshold_ms: u64,
}

Same-room router cap and packet-loop health threshold.

A room’s first join selects the first healthy worker in its cyclic search order or the least-delayed worker when none qualify. With more than one local router allowed, later joins prefer the least-delayed healthy assigned worker. If none qualifies, another router may be allocated on an unused healthy worker up to max_local_routers and the worker count. Missing delay samples and values at or above packet_loop_delay_threshold_ms are unhealthy. If no healthy placement exists, the least-delayed assigned worker is reused.

Fields

max_local_routers: usize

packet_loop_delay_threshold_ms: u64

Implementations

impl RoomWorkerPolicy

pub const DEFAULT_PACKET_LOOP_DELAY_THRESHOLD_MS: u64 = 20

pub const fn strict_single_router() -> Self

pub const fn new( max_local_routers: NonZeroUsize, packet_loop_delay_threshold_ms: NonZeroU64, ) -> Self

pub const fn max_local_routers(self) -> usize

pub const fn packet_loop_delay_threshold_ms(self) -> u64

Trait Implementations

impl Clone for RoomWorkerPolicy

fn clone(&self) -> RoomWorkerPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoomWorkerPolicy

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

Formats the value using the given formatter.

impl Default for RoomWorkerPolicy

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for RoomWorkerPolicy

fn eq(&self, other: &RoomWorkerPolicy) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for RoomWorkerPolicy

impl Eq for RoomWorkerPolicy

impl StructuralPartialEq for RoomWorkerPolicy