Struct WebSocketServer 

pub struct WebSocketServer { /* private fields */ }

Implementations

impl WebSocketServer

pub fn new( bind_addr: SocketAddr, bus_manager: BusManager, entity_cache: EntityCache, view_index: Arc<ViewIndex>, ) -> Self

pub fn with_max_clients(self, max_clients: usize) -> Self

pub fn with_auth_plugin(self, auth_plugin: Arc<dyn WebSocketAuthPlugin>) -> Self

pub fn with_usage_emitter( self, usage_emitter: Arc<dyn WebSocketUsageEmitter>, ) -> Self

pub fn with_journal(self, journal: Arc<EventJournal>) -> Self

Serve replayable append subscriptions from the retained event journal.

pub fn with_rate_limit_config(self, config: RateLimitConfig) -> Self

pub fn with_delivery_config(self, config: WebSocketDeliveryConfig) -> Self

pub async fn start(self) -> Result<()>

Bind the configured address and serve connections until the task is dropped. Equivalent to into_acceptor followed by [ConnectionAcceptor::serve_listener].