Struct ClusterSingletonProxy 

pub struct ClusterSingletonProxy {
    pub manager: Arc<ClusterSingletonManager>,
}

Proxy that routes messages to the current singleton, buffering during handover.

Fields

manager: Arc<ClusterSingletonManager>

Implementations

impl ClusterSingletonProxy

pub fn new(manager: Arc<ClusterSingletonManager>) -> Self

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

pub fn send<F>(&self, deliver: F) -> bool

where F: FnOnce(&UntypedActorRef) + Send + 'static,

Schedule deliver against the singleton. If Active, runs immediately; if Inactive/Starting/HandingOver, buffers for replay. Returns false if the buffer was full.