Struct GlobalRegistry 

pub struct GlobalRegistry {
    pub stats: Arc<PubSubStats>,
    /* private fields */
}

Fields

stats: Arc<PubSubStats>

Implementations

impl GlobalRegistry

pub fn new(num_threads: usize) -> (Arc<Self>, Vec<Receiver<BroadcastMsg>>)

pub fn add_channel_interest(&self, channel: Vec<u8>, thread_id: ThreadId)

pub fn remove_channel_interest(&self, channel: &[u8], thread_id: ThreadId)

pub fn add_pattern_interest(&self, pattern: Vec<u8>, thread_id: ThreadId)

pub fn remove_pattern_interest(&self, pattern: &[u8], thread_id: ThreadId)

pub fn get_channel_threads(&self, channel: &[u8]) -> Vec<ThreadId>

pub fn get_all_pattern_threads(&self) -> HashSet<ThreadId>

pub fn broadcast_to_threads(&self, msg: BroadcastMsg, thread_ids: &[ThreadId])

pub fn broadcast_to_all_threads( &self, msg: BroadcastMsg, exclude: Option<ThreadId>, )

pub fn get_all_channels(&self) -> Vec<Vec<u8>>

pub fn get_channel_subscriber_count(&self, channel: &[u8]) -> usize

pub fn increment_channel_subscribers(&self, channel: &[u8])

pub fn decrement_channel_subscribers(&self, channel: &[u8])

pub fn increment_pattern_subscribers(&self, pattern: &[u8])

pub fn decrement_pattern_subscribers(&self, pattern: &[u8])

pub fn get_pattern_subscriber_count(&self, pattern: &[u8]) -> usize

pub fn get_total_pattern_matches(&self, channel: &[u8]) -> usize

pub fn glob_match(pattern: &[u8], text: &[u8]) -> bool

pub fn get_pattern_count(&self) -> usize