Struct ClusterSingletonManager 

pub struct ClusterSingletonManager { /* private fields */ }

Decides which node hosts the singleton based on oldest up-member — a hook is provided so tests can simulate handover without wiring the full cluster.

Implementations

impl ClusterSingletonManager

pub fn new() -> Arc<Self>

pub fn with_buffer_size(size: usize) -> Arc<Self>

Construct with a custom proxy buffer size.

pub fn state(&self) -> SingletonState

pub fn set_active_here(&self, r: UntypedActorRef)

Mark r as the local singleton (we won the election). Flushes any messages that were buffered during handover.

pub fn set_active_remote(&self, r: UntypedActorRef)

Mark r as the remote singleton (some other node is hosting it).

pub fn begin_handover(&self)

Begin handover (we used to be Active(here)).

pub fn begin_starting(&self)

Begin starting (we were elected as the new oldest).

pub fn clear(&self)

Forget the current singleton entirely.

pub fn current(&self) -> Option<UntypedActorRef>

pub fn buffered(&self) -> usize

Number of currently-buffered messages (waiting for handover to complete).

pub fn drops(&self) -> u64

Total number of messages dropped due to buffer-full overflow.

Trait Implementations

impl Default for ClusterSingletonManager

fn default() -> Self

Returns the “default value” for a type.