Struct RoomManager 

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

Coordinates current room admission and lifecycle.

Fields

directory: RwLock<RoomDirectory>

factory: RoomFactory

reservation_ttl: Duration

Implementations

impl RoomManager

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

builds a room manager with an empty directory

pub async fn serve_room( &self, issuer: &str, key: &str, 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 key, config and remote_address. 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 policy for rooms dirtied by media activity

empty input is a no-op. rooms that left the current directory before the drain are skipped. committed route work is executed after each policy plan so transport routing and accepted selector state stay in sync

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::RouterState when router placement cannot commit.

Panics

Panics when existing relay state refers to an uncommitted source placement.

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, remove_if_empty: bool, ) -> Option<(Arc<Room>, T)>

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

async fn finish_session_mutation( &self, room_id: &str, mutation: CurrentRoomMutation, remove_if_empty: bool, )

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

accepts work only against the directory-current room row

the returned mutation holds no directory lock. if the row is replaced between snapshot and current check, the lease is cancelled and the caller sees None

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

async fn is_current_entry(&self, room_id: &str, room: &Arc<Room>) -> bool

Trait Implementations

impl Debug for RoomManager

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

Formats the value using the given formatter.