Struct RoomManager 

pub struct RoomManager {
    directory: RwLock<RoomDirectory>,
    factory: RoomFactory,
    reservation_ttl: Duration,
    departure_grace: Duration,
    policy_permits: Semaphore,
}

Coordinates current room admission and lifecycle.

Fields

directory: RwLock<RoomDirectory>

factory: RoomFactory

reservation_ttl: Duration

departure_grace: Duration

policy_permits: Semaphore

Implementations

impl RoomManager

pub fn new( runtime_policy: RoomRuntimePolicy, metrics: Arc<RuntimeMetrics>, reservation_ttl: Duration, departure_grace: Duration, ) -> Self

builds a room manager with an empty directory

pub async fn serve_room( &self, issuer: &str, key: SecretSlice<u8>, config: &RoomConfig, remote_address: Option<&str>, ) -> Result<Arc<Room>, RoomManagerServeError>

Returns the current room for issuer or publishes a new reservation.

The first reservation fixes decoded key bytes, config and remote address. The admitting runtime validates key encoding and strength before this call. Matching requests return the same room and renew an outstanding reservation without rearming one retired by a successful join.

Errors

Returns RoomManagerServeError::ConflictingReservation when the current room has a different key or config.

pub async fn get_by_uuid(&self, uuid: &str) -> Option<Arc<Room>>

returns the current room for a public room uuid

pub async fn stats_snapshots( &self, media_transport: &MediaTransport, ) -> Vec<RuntimeRoomStatsSnapshot>

builds /v1/stats rows from one directory snapshot

the directory lock is released before transport stats are read, so the returned rows are best-effort runtime observations rather than a global transaction across room and media state

pub async fn directory_snapshots(&self) -> Vec<RuntimeRoomDirectorySnapshot>

returns current directory rows for room diagnostics

pub async fn room_gauges(&self) -> RoomGaugeValues

Returns counts from rooms in one directory snapshot.

Room states are read sequentially after the directory lock is released. Removed rooms may contribute once. New rooms appear on the next call.

pub async fn directory_snapshot( &self, room_id: &str, ) -> Option<RuntimeRoomDirectorySnapshot>

returns one current directory row for room diagnostics

pub async fn sync_source_packet_selection_policies_for_runtime_ids( &self, room_instance_ids: &BTreeSet<RoomInstanceId>, media_transport: &MediaTransport, )

Recalculates packet selection for the requested current rooms.

pub async fn source_policy_turns<'a>( &'a self, room_instance_ids: &BTreeSet<RoomInstanceId>, media_transport: &'a MediaTransport, ) -> BoxStream<'a, RoomInstanceId>

Yields each requested room after its ordered policy turn completes.

Worker reads are shared within the batch. Missing rooms also complete. Failed observations schedule a retry before completing their room. Dropping the stream cancels pending turns, including accepted effects.

pub async fn join_user( &self, room_id: &str, request: JoinUserRequest, media_transport: &MediaTransport, ) -> Result<RoomUserAdmission, RoomManagerJoinError>

Admits one WebSocket connection into a current room.

Returns after join-side room effects complete.

Errors

Returns RoomManagerJoinError::MissingRoom when room_id is not current. Returns RoomManagerJoinError::RoomFull when a new user exceeds room capacity. Returns RoomManagerJoinError::NoUsableWorker when no worker can accept placement and RoomManagerJoinError::RouterState when router placement cannot commit.

pub async fn close_session( &self, room_id: &str, user_id: &UserId, connection_id: ConnectionId, media_transport: &MediaTransport, ) -> bool

closes one room connection and then re-checks empty-room removal

returns false when the room is missing or the connection was not removed by this call. the empty current room can still be removed after stale or already-completed teardown

pub async fn disconnect_users( &self, room_id: &str, user_ids: &[UserId], media_transport: &MediaTransport, )

disconnects selected users from a current room and removes it if empty

missing rooms are ignored because the caller’s disconnect intent is already satisfied

pub async fn check_expired_room_reservations(&self)

Claims and removes expired reservations with no active room mutations.

async fn run_current_room_mutation<T, F, Fut>( &self, room_id: &str, action: F, on_empty: Option<RoomRemovalPolicy>, ) -> Option<T>

where F: FnOnce(Arc<Room>) -> Fut, Fut: Future<Output = T>,

async fn finish_session_mutation( &self, room_id: &str, mutation: CurrentRoomMutation, on_empty: Option<RoomRemovalPolicy>, )

async fn begin_current_room_mutation( &self, room_id: &str, ) -> Option<CurrentRoomMutation>

Accepts work while the directory read guard proves the row is current.

The returned lease protects subsequent room work without retaining the directory guard.

async fn entry(&self, room_id: &str) -> Option<RoomDirectoryEntry>

async fn directory_entries(&self) -> Vec<RoomDirectoryEntry>

async fn directory_entries_for_instance_ids( &self, room_instance_ids: &BTreeSet<RoomInstanceId>, ) -> Vec<Arc<Room>>

async fn entry_stats_snapshot( &self, entry: RoomDirectoryEntry, media_transport: &MediaTransport, ) -> RuntimeRoomStatsSnapshot

Trait Implementations

impl Debug for RoomManager

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

Formats the value using the given formatter.