Struct RactorClusterEvents 

pub struct RactorClusterEvents { /* private fields */ }

A dactor ClusterEvents implementation for the ractor adapter.

Provides a callback-based subscription system. In production, an integration with ractor_cluster would feed real membership changes into this subsystem via RactorClusterEvents::emit.

Implementations

impl RactorClusterEvents

pub fn new() -> Self

Create a new cluster events subsystem.

pub fn emit(&self, event: ClusterEvent)

Emit a cluster event, notifying all subscribers.

Callbacks are snapshot-cloned before invocation so that subscribers may safely call subscribe or unsubscribe from within a callback without deadlocking.

In production, this would be driven by ractor_cluster membership change notifications. For testing, call this directly.

Trait Implementations

impl Clone for RactorClusterEvents

fn clone(&self) -> RactorClusterEvents

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterEvents for RactorClusterEvents

fn subscribe( &self, on_event: Box<dyn Fn(ClusterEvent) + Send + Sync>, ) -> Result<SubscriptionId, ClusterError>

Subscribe to cluster membership changes. The callback is invoked for each ClusterEvent (NodeJoined, NodeLeft, NodeRejected). Returns a SubscriptionId that can be used to cancel the subscription.

fn unsubscribe(&self, id: SubscriptionId) -> Result<(), ClusterError>

Remove a previously registered subscription. Idempotent.

impl Default for RactorClusterEvents

fn default() -> Self

Returns the “default value” for a type.