Struct ClusterSync 

pub struct ClusterSync { /* private fields */ }

Propagates channel subscriptions and fans published messages out across the cluster via beamr process groups (SRV-005 R5/R6).

Implementations

impl ClusterSync

pub fn new( pg: Arc<PgRegistry>, atoms: Arc<AtomTable>, connections: ConnectionManager, local_node: Atom, resolver: Arc<ClusterResolver>, ) -> Self

Builds a sync over the scheduler’s pg registry and distribution connections. local_node is this node’s distribution atom (interned from the configured node name in the SAME atom table).

pub fn remote_targets(&self, channel: &str) -> Vec<RemoteMember>

Remote members of channel’s group (for publish fan-out and tests).

impl ClusterSync

pub fn on_peer_join(&self, node: Atom)

R5 backfill: re-advertise every local subscription to a newly-joined peer.

pub fn on_peer_leave(&self, node: Atom)

R6 is automatic (beamr purges the departed node’s remote members via its connection-down hook). This logs the cleanup for operators.

Trait Implementations

impl Clone for ClusterSync

fn clone(&self) -> ClusterSync

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ClusterObserver for ClusterSync

fn on_subscribe(&self, channel: &str, subscriber_pid: u64)

A local subscriber (beamr pid subscriber_pid) joined channel.

fn on_unsubscribe(&self, channel: &str, subscriber_pid: u64)

A local subscriber (beamr pid subscriber_pid) left channel.

fn on_publish(&self, channel: &str, envelope: &Envelope)

A message was published to channel on this node; the observer may fan it out to remote subscribers.

impl Debug for ClusterSync

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.