Struct CollaborationServer 

pub struct CollaborationServer { /* private fields */ }

YrsManager 的包装器，用于处理动态房间创建和广播组管理

Implementations

impl CollaborationServer

pub fn new(yrs_manager: Arc<YrsManager>, port: u16) -> Self

pub fn with_sync_service( yrs_manager: Arc<YrsManager>, sync_service: Arc<SyncService>, port: u16, ) -> Self

使用现有的 SyncService 创建服务器

pub async fn handle_rejection(err: Rejection) -> Result<impl Reply, Infallible>

自定义错误处理器

pub async fn offline_room(&self, room_id: &str, save_data: bool) -> Result<bool>

房间下线 - 优雅关闭房间

1. 通知所有客户端房间即将关闭
2. 等待客户端完成当前操作
3. 保存数据（可选）
4. 清理资源

pub async fn force_offline_room(&self, room_id: &str) -> Result<bool>

强制房间下线 - 紧急情况使用

pub async fn offline_rooms( &self, room_ids: &[String], save_data: bool, ) -> Result<Vec<(String, bool)>>

批量下线房间

pub fn get_active_rooms(&self) -> Vec<String>

获取所有活跃房间列表

pub async fn get_rooms_stats(&self) -> Vec<RoomInfo>

获取房间统计信息

pub async fn offline_rooms_by_condition<F>( &self, condition: F, save_data: bool, ) -> Result<Vec<String>>

where F: Fn(&RoomInfo) -> bool,

根据条件下线房间 例如：下线空闲时间超过指定时间的房间、下线没有客户端的房间等

pub async fn offline_empty_rooms(&self, save_data: bool) -> Result<Vec<String>>

下线空房间（没有客户端连接的房间）

pub async fn offline_inactive_rooms( &self, inactive_duration: Duration, save_data: bool, ) -> Result<Vec<String>>

下线长时间未活动的房间

pub async fn shutdown(&self, save_all_data: bool) -> Result<()>

服务器完全关闭 - 下线所有房间

pub async fn start(self)

启动 WebSocket 服务器

pub fn sync_service(&self) -> &Arc<SyncService>

获取 SyncService 的引用，用于外部操作

Trait Implementations

impl Clone for CollaborationServer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.