pub(crate) struct RoomFactory {
runtime_policy: RoomRuntimePolicy,
metrics: Arc<RuntimeMetrics>,
allocator: Mutex<RoomRuntimeAllocator>,
}Expand description
Cold-path constructor for rooms that are new to the directory.
RoomFactory keeps runtime-wide creation dependencies behind the manager
so RoomManager::serve_room can focus on idempotent lookup and
publication. Each call to Self::create returns an unpublished
Room with fresh process-local placement. The caller must insert it in
the directory before exposing it to other runtime entrypoints.
Fields§
§runtime_policy: RoomRuntimePolicyRuntime-wide room rules cloned into each room.
Keeping the policy here makes every room start from the validated boot-time policy while still letting the room own its copy.
metrics: Arc<RuntimeMetrics>Process metric catalog cloned into each room.
allocator: Mutex<RoomRuntimeAllocator>Serialized allocator for process-local placement ids.
This keeps concurrent create requests from receiving the same runtime placement.
Implementations§
Source§impl RoomFactory
impl RoomFactory
Sourcepub(crate) fn new(
runtime_policy: RoomRuntimePolicy,
metrics: Arc<RuntimeMetrics>,
) -> Self
pub(crate) fn new( runtime_policy: RoomRuntimePolicy, metrics: Arc<RuntimeMetrics>, ) -> Self
Builds the factory for one RoomManager lifetime.
Sourcepub(crate) fn create(
&self,
issuer: &str,
key: &str,
config: &RoomConfig,
) -> Arc<Room>
pub(crate) fn create( &self, issuer: &str, key: &str, config: &RoomConfig, ) -> Arc<Room>
Creates an unpublished room from one manager lookup miss
The room emits no creation diagnostics. RoomManager publishes it
before emitting its creation event
Sourcefn allocate_runtime_context(&self) -> RoomRuntimeContext
fn allocate_runtime_context(&self) -> RoomRuntimeContext
Reserves runtime-local placement for one new room.
The primary router id is allocated here, but worker placement remains unset until the first session join assigns the room from live load data.
The mutex is poisoned-tolerant because placement allocation has no partial side effect beyond the counters themselves. Recovering the inner value keeps later room creation possible after an unrelated panic.
Sourcepub(super) fn allocate_spillover_router(&self) -> RouterId
pub(super) fn allocate_spillover_router(&self) -> RouterId
reserve a new process-unique identifier for a spillover router
this provides the room engine with a thread-safe way to allocate new router identities on the fly when media load exceeds the primary worker capacity. the allocator lock is held only long enough to increment the counter, keeping the cold-path creation from blocking active request loops
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for RoomFactory
impl RefUnwindSafe for RoomFactory
impl Send for RoomFactory
impl Sync for RoomFactory
impl Unpin for RoomFactory
impl UnsafeUnpin for RoomFactory
impl UnwindSafe for RoomFactory
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more