Struct PresenceManager 

pub struct PresenceManager { /* private fields */ }

Manages room-based presence state.

Thread-safe via RwLock for the room map and atomics for counters.

Implementations

impl PresenceManager

pub fn new(config: PresenceConfig) -> Self

Create a new presence manager.

pub async fn join( &self, room: &str, member_id: &str, state: Value, ) -> Result<(PresenceState, PresenceDiff), PresenceError>

Join a room with initial state.

Returns PresenceState (current members including the new one) and a PresenceDiff (announcing the join) for broadcasting.

Errors

Returns error if the room is full or room limit is exceeded.

pub async fn leave(&self, room: &str, member_id: &str) -> Option<PresenceDiff>

Leave a room.

Returns a PresenceDiff for broadcasting, or None if the member wasn’t in the room.

pub async fn heartbeat(&self, room: &str, member_id: &str) -> bool

Record a heartbeat for a member, resetting their eviction timer.

Returns true if the heartbeat was accepted (member exists in room).

pub async fn update_state( &self, room: &str, member_id: &str, new_state: Value, ) -> Option<PresenceDiff>

Update a member’s state payload.

Returns a PresenceDiff with the updated member in joins (same semantics as Supabase Realtime — updates appear as joins).

pub async fn evict_stale(&self) -> Vec<PresenceDiff>

Evict members whose heartbeat has expired.

Returns PresenceDiff events for each room that had evictions.

pub async fn get_room(&self, room: &str) -> Option<PresenceState>

Get current members of a room.

pub async fn stats(&self) -> PresenceStats

Get statistics.

Trait Implementations

impl Debug for PresenceManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.