Struct ClusterClient 

pub struct ClusterClient {
    pub receptionist: Arc<ClusterReceptionist>,
    /* private fields */
}

Fields

receptionist: Arc<ClusterReceptionist>

Implementations

impl ClusterClient

pub fn new(receptionist: Arc<ClusterReceptionist>) -> Self

pub fn with_settings( receptionist: Arc<ClusterReceptionist>, settings: ClusterClientSettings, ) -> Self

pub fn send(&self, name: &str) -> Option<UntypedActorRef>

Direct receptionist lookup (in-process / single-node case).

pub fn next_contact(&self) -> Option<String>

Pick the next initial contact (round-robin). Returns None if initial_contacts is empty.

pub async fn establish<F>( &self, try_resolve: F, ) -> Result<UntypedActorRef, ClusterClientError>

where F: FnMut(&str) -> Option<UntypedActorRef>,

establish — drive contact-point discovery using try_resolve until it returns Some(_) or max_attempts is exhausted. Sleeps establishing_get_contacts_interval between attempts.