Struct RedisPubSub 

pub struct RedisPubSub { /* private fields */ }

Redis pub/sub backend for cross-instance WebSocket broadcast.

When a server instance needs to broadcast to a room, it publishes to a Redis channel. All instances subscribe to these channels and route messages to their locally connected clients.

Implementations

impl RedisPubSub

pub fn new(pool: Arc<Pool>) -> Self

Creates a new Redis pub/sub backend.

pub async fn publish(&self, msg: &PubSubMessage) -> Result<(), ShaperailError>

Publishes a broadcast message to Redis so all instances receive it.

pub fn start_subscriber( &self, channel_name: &str, room_manager: RoomManager, redis_url: &str, ) -> JoinHandle<()>

Starts a subscriber task that listens on Redis pub/sub and routes messages to the local room manager.

This spawns a background Tokio task that runs until the returned tokio::task::JoinHandle is aborted.

Trait Implementations

impl Clone for RedisPubSub

fn clone(&self) -> RedisPubSub

Returns a duplicate of the value.

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

Performs copy-assignment from source.