Struct RealtimeManager 

pub struct RealtimeManager { /* private fields */ }

Manages WebSocket connections and SSE subscriptions.

Each event broadcast through RealtimeManager::broadcast is:

1. Assigned a monotonically-increasing seq_id.
2. Pushed into an in-memory ring buffer (capacity [DEFAULT_MAX_BUFFERED_EVENTS]).
3. Sent over the tokio broadcast channel for live subscribers.

Clients that reconnect with a Last-Event-Id header can call RealtimeManager::get_events_after to retrieve buffered events they missed.

Implementations

impl RealtimeManager

pub fn new() -> Self

Create a new realtime manager with the default buffer size (500 events).

pub fn with_buffer_size(max_buffered_events: usize) -> Self

Create a realtime manager with a custom ring-buffer size.

pub fn broadcast(&self, event: RealtimeEvent)

Broadcast an event to all matching clients.

The event is stamped with a sequential seq_id, pushed into the ring buffer, and sent over the broadcast channel.

pub fn get_events_after(&self, last_seq_id: u64) -> Vec<RealtimeEvent>

Return all buffered events whose seq_id is strictly greater than last_seq_id, in ascending order. Used to replay missed events for reconnecting clients.

pub fn current_seq(&self) -> u64

Return the current value of the sequence counter (next ID to be issued). Mainly useful for tests.

pub fn client_count(&self) -> usize

Get number of connected clients

pub fn subscribe(&self) -> Receiver<RealtimeEvent>

Subscribe to live events

pub fn register_client(&self, id: String, filter: SubscriptionFilter)

Register a new client

pub fn unregister_client(&self, id: &str)

Unregister a client

pub fn get_client_filter(&self, id: &str) -> Option<SubscriptionFilter>

Get client filter

Trait Implementations

impl Clone for RealtimeManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RealtimeManager

fn default() -> Self

Returns the “default value” for a type.