Struct cluster_mode::Cluster

pub struct Cluster { /* private fields */ }

Describes a cluster, including operating mode, primaries & secondaries

Implementations

impl Cluster

pub fn new(update_interval: u64) -> Self

Initialize Cluster

Arguments

• update_interval - milliseconds, Interval between discovery service call

pub async fn secondaries(&self) -> Option<Arc<HashSet<RestClusterNode>>>

Get the list of secondaries. Returns None if Cluster is inactive or in Secondary mode. List can be empty.

pub async fn primaries(&self) -> Option<HashSet<RestClusterNode>>

Get the list of primaries. Returns None if Cluster is inactive or in Primary mode. List can be empty.

pub async fn is_primary(&self) -> bool

true if Cluster mode is Primary

pub async fn is_secondary(&self) -> bool

true if Cluster mode is Secondary

pub async fn is_active(&self) -> bool

true if Cluster mode is not Inactive

pub async fn accept_raft_request_vote(
    &self,
    requester_node_id: String,
    term: usize
)

Forward almost_raft::Message::RequestVote message to Raft process

pub async fn accept_raft_request_vote_resp(&self, term: usize, vote: bool)

Forward almost_raft::Message::RequestVoteResponse message to Raft process

pub async fn accept_raft_heartbeat(&self, leader_node_id: String, term: usize)

Forward almost_raft::Message::HeartBeat message to Raft process

pub async fn get_service_instance(&self) -> Option<ServiceInstance>

get the service instance of this cluster node

Trait Implementations

impl Default for Cluster

fn default() -> Self

Returns the “default value” for a type.