Struct SubscriberRegistry 

pub struct SubscriberRegistry { /* private fields */ }

Subscriber registry for managing service subscriptions

Implementations

impl SubscriberRegistry

pub fn new() -> Self

pub fn subscribe( &self, namespace: &str, group_name: &str, service_name: &str, listener: Arc<dyn ServiceListener>, )

Subscribe to a service

pub fn unsubscribe(&self, namespace: &str, group_name: &str, service_name: &str)

Unsubscribe from a service

pub fn has_subscribers( &self, namespace: &str, group_name: &str, service_name: &str, ) -> bool

Check if a service has subscribers

pub async fn notify(&self, event: ServiceChangeEvent)

Notify listeners of a service change

pub fn get_subscribed_services(&self) -> Vec<(String, String, String)>

Get all subscribed service keys

pub fn subscriber_count(&self) -> usize

Get subscriber count

pub fn clear(&self)

Clear all subscriptions

Trait Implementations

impl Default for SubscriberRegistry

fn default() -> Self

Returns the “default value” for a type.