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 set_peer_listener(&self, listener: PeerListener) -> bool

Installs the listener every peer join and leave is reported to. A second listener is refused (answers false): the first keeps the seat.

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) -> Self

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, once per departure: from the host thread of an explicit unsubscribe, or, when the subscription was dropped without one (its connection closed, it was shed), from the channel actor’s thread as it prunes the dead subscriber. On the actor’s thread the observer must not wait on that 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.