Struct ClusterState 

pub struct ClusterState {
    pub self_node: String,
    pub members: BTreeMap<String, Member>,
}

Immutable current membership snapshot.

Fields

self_node: String

Local node id for the node that produced this view.

members: BTreeMap<String, Member>

Members keyed by logical node id.

Implementations

impl ClusterState

pub fn member(&self, node_id: &str) -> Option<&Member>

Return a member by node id.

pub fn up_members(&self) -> Vec<&Member>

Return all members currently in Up state and reachable.

pub fn placement_coordinator(&self) -> Option<&Member>

Return the deterministic placement coordinator for this membership view.

Datum v0.10 mirrors Akka’s “oldest member” coordinator convention without adding a consensus protocol. C1 does not assign Akka-style up numbers, so the ordering key is the propagated member incarnation, then node id. Every node computes the same answer from the same C1 view. Under a partition and timeout downing, different views can transiently produce different coordinators; quorum or lease fencing is a v0.11+ follow-up.

pub fn is_placement_coordinator(&self, node_id: &str) -> bool

Return true when node_id is the coordinator in this view.

Trait Implementations

impl Clone for ClusterState

fn clone(&self) -> ClusterState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for ClusterState

impl PartialEq for ClusterState

fn eq(&self, other: &ClusterState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ClusterState