Struct MembershipState 

pub struct MembershipState {
    pub members: Vec<Member>,
    pub reachability: Reachability,
}

Fields

members: Vec<Member>

reachability: Reachability

Implementations

impl MembershipState

pub fn new() -> Self

pub fn add_or_update(&mut self, m: Member)

pub fn remove(&mut self, addr: &Address)

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

pub fn unreachable_addresses(&self) -> BTreeSet<String>

pub fn member_count(&self) -> usize

pub fn apply_leader_actions(&mut self) -> Vec<ClusterEvent>

Run the leader’s per-tick transition logic against the current state. Returns the ClusterEvents the daemon should publish (membership status flips, removals).

Phase 6.C of docs/full-port-plan.md. Pure function — keeps the daemon actor itself trivial: collect events, then publish onto crate::events::ClusterEventBus.

pub fn join(&mut self, m: Member) -> ClusterEvent

Insert m as a Joining member and emit the MemberJoined event for the daemon to publish.

pub fn leave(&mut self, addr: &Address) -> Option<ClusterEvent>

Mark addr as leaving. Returns the published event if the transition was valid, None if no such member exists.

pub fn down(&mut self, addr: &Address) -> Option<ClusterEvent>

Force addr to Down. Unlike Self::leave, this is the operator-initiated terminal-down path: it accepts members in Up, WeaklyUp, or Leaving status. The next leader-action tick promotes Down → Removed.

Returns the ClusterEvent::MemberDowned if a transition occurred, or None if the member is unknown or already in a terminal status (Down, Exiting, Removed, Joining).

Trait Implementations

impl Clone for MembershipState

fn clone(&self) -> MembershipState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MembershipState

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

Formats the value using the given formatter.

impl Default for MembershipState

fn default() -> MembershipState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MembershipState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MembershipState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.