Struct ClusterPubSub 

pub struct ClusterPubSub { /* private fields */ }

Mediator that augments a local DistributedPubSub with a cross-node topic table + transport. Clusters publish via ClusterPubSub::publish_remote which fans out to all nodes that have advertised the topic; receivers route the payload to local subscribers using the codec registry.

Implementations

impl ClusterPubSub

pub fn new( local: Arc<DistributedPubSub>, self_node: impl Into<String>, transport: Arc<dyn MediatorTransport>, ) -> Arc<Self>

pub fn register_decoder<F>(&self, type_id: impl Into<String>, decode: F)

where F: Fn(&[u8]) -> bool + Send + Sync + 'static,

Register a per-message-type decoder for inbound Forward PDUs. type_id typically matches std::any::type_name::<M>(); the decoder must deliver to local subscribers (and return true if any delivery happened).

pub fn announce_to(&self, target_node: &str)

Announce currently-subscribed topics to a peer node. Caller drives this on a tick (similar to ClusterDaemon).

pub fn apply_pdu(&self, pdu: MediatorPdu)

Apply an inbound PDU received from the transport.

pub fn publish_remote<M, S>( &self, topic: &str, msg: M, type_id: impl Into<String>, encode: S, ) -> usize

where M: Clone + Send + 'static, S: FnOnce(&M) -> Vec<u8>,

Cross-node publish. Locally fan-out via the wrapped mediator, then forward the serialized payload to every remote node that has announced this topic.

pub fn known_remote_topics(&self) -> usize

pub fn nodes_for(&self, topic: &str) -> Vec<String>