Struct PubSubManager 

pub struct PubSubManager { /* private fields */ }

Pub/Sub manager for handling channel subscriptions and message broadcasting

Implementations

impl PubSubManager

pub fn new(cleanup_interval: Duration, subscription_timeout: Duration) -> Self

Create a new pub/sub manager

pub fn start_cleanup(&mut self)

Start the background cleanup task

pub fn stop_cleanup(&mut self)

Stop the background cleanup task

pub async fn subscribe( &self, pattern: ChannelPattern, ) -> KVResult<UnboundedReceiver<PubSubMessage>>

Subscribe to a channel pattern

Errors

Returns error if subscription setup fails

pub async fn unsubscribe(&self, pattern: &ChannelPattern) -> KVResult<usize>

Unsubscribe from a channel pattern

Errors

Returns error if unsubscription fails

pub async fn publish(&self, channel: &str, message: Value) -> KVResult<usize>

Publish a message to a channel

Errors

Returns error if publishing fails

pub async fn get_stats(&self) -> KVResult<PubSubStats>

Get statistics about subscriptions

Errors

Returns error if stats calculation fails

pub async fn get_active_patterns(&self) -> KVResult<Vec<ChannelPattern>>

Get all active channel patterns

Errors

Returns error if pattern retrieval fails

Trait Implementations

impl Default for PubSubManager

fn default() -> Self

Returns the “default value” for a type.

impl Drop for PubSubManager

fn drop(&mut self)

Executes the destructor for this type.