Struct DistributedPubSub 

pub struct DistributedPubSub { /* private fields */ }

Implementations

impl DistributedPubSub

pub fn new() -> Arc<Self>

pub fn subscribe<M: Clone + Send + 'static>( &self, topic: impl Into<String>, subscriber: ActorRef<M>, )

Subscribe subscriber: ActorRef<M> to topic. Future publish_msg::<M>(topic, msg) calls deliver to it.

pub fn subscribe_to_group<M: Clone + Send + 'static>( &self, topic: impl Into<String>, group: impl Into<String>, subscriber: ActorRef<M>, )

Subscribe to a (topic, group) bucket. send_to_group rotates through bucket members.

pub fn unsubscribe(&self, topic: &str, subscriber_path: &ActorPath)

Drop a subscriber by path from a topic.

pub fn publish(&self, topic: &str) -> Vec<UntypedActorRef>

Snapshot of subscriber refs for a topic. Useful for tests + the legacy “discover, then send” pattern.

pub fn publish_msg<M: Clone + Send + 'static>( &self, topic: &str, msg: M, ) -> usize

Typed broadcast. Delivers msg (cloned) to every subscriber of topic. Returns the number of successful deliveries.

pub fn send_to_group<M: Clone + Send + 'static>( &self, topic: &str, group: &str, msg: M, ) -> bool

Pick one member of (topic, group) round-robin and deliver msg. Returns true if a recipient was found.

pub fn topic_count(&self) -> usize

pub fn group_count(&self) -> usize

Trait Implementations

impl Default for DistributedPubSub

fn default() -> DistributedPubSub

Returns the “default value” for a type.