Struct WsServer 

pub struct WsServer { /* private fields */ }

WebSocket 服务端

Implementations

impl WsServer

pub fn new( listen_addr: String, config: ServerConfig, connections: Arc<DashMap<u64, ClientConn>>, router: Arc<RequestRouter>, subscriptions: Option<Arc<SubscriptionManager>>, ) -> Self

创建 WsServer，共享 TCP 的连接池、路由器、订阅管理器（无鉴权，向后兼容）

pub fn with_auth( listen_addr: String, config: ServerConfig, deps: WsServerDeps, key_store: Option<Arc<KeyStore>>, counters: Option<Arc<RuntimeCounters>>, ) -> Self

v1.0 入口：同时接入 KeyStore + 共享 RuntimeCounters 做握手鉴权和 per-message scope / 限额检查。key_store = None 或未配置时保持 legacy（全放行）。

pub fn with_server_time_store(self, store: Arc<ServerTimeAnchorStore>) -> Self

Inject the shared backend server-time anchor for SDK-facing WS fields.

pub fn with_filter_registry(self, registry: Arc<FilterRegistry>) -> Self

v1.4.104 阶段 3: 注入显式 FilterRegistry (跨 surface 共享同一份). 不调用此 setter 则 run() 时 fallback 到 FilterRegistry::with_defaults().

pub async fn run(&self) -> Result<()>

启动 WebSocket 服务端监听

pub async fn run_until_shutdown( &self, shutdown_rx: Receiver<bool>, ) -> Result<()>

启动 WebSocket 服务端监听，并在 shutdown 信号到来时停止接受新连接。

pub async fn run_until_shutdown_with_listener_events( &self, shutdown_rx: Receiver<bool>, listener_events: Option<ListenerBindEventSender>, ) -> Result<()>

Run until shutdown and report the exact socket bind result to startup.