Struct RepGroup 

pub struct RepGroup { /* private fields */ }

A replication group consisting of named nodes.

The group tracks its members and provides queries for electable nodes, monitors, quorum size, etc. Each node in the group has a unique name.

Implementations

impl RepGroup

pub fn new(name: String, group_id: u64) -> Self

Creates a new replication group with the given name and ID.

Defaults to QuorumPolicy::SimpleMajority. Use RepGroup::with_policy to specify a Flexible or Expression policy.

pub fn with_policy(name: String, group_id: u64, policy: QuorumPolicy) -> Self

Creates a new replication group with an explicit quorum policy.

pub fn set_quorum_policy(&mut self, policy: QuorumPolicy)

Replace the quorum policy for this group.

pub fn quorum_policy(&self) -> &QuorumPolicy

Returns a reference to the current quorum policy.

pub fn name(&self) -> &str

Returns the group name.

pub fn group_id(&self) -> u64

Returns the group ID.

pub fn add_node(&mut self, node: RepNode) -> Option<RepNode>

Adds a node to the group. Returns the previous node with the same name, if any.

pub fn remove_node(&mut self, name: &str) -> Option<RepNode>

Removes a node from the group by name. Returns the removed node, if it existed.

pub fn get_node(&self, name: &str) -> Option<&RepNode>

Returns a reference to the node with the given name, if present.

pub fn get_nodes(&self) -> Vec<&RepNode>

Returns all nodes in the group.

pub fn get_electable_nodes(&self) -> Vec<&RepNode>

Returns all electable nodes (those that participate in elections).

pub fn get_monitors(&self) -> Vec<&RepNode>

Returns all monitor nodes.

pub fn electable_count(&self) -> u32

Returns the number of electable nodes in the group.

pub fn phase1_quorum(&self) -> usize

Returns the Phase 1 (Prepare/Promise) quorum size under the current policy.

pub fn phase2_quorum(&self) -> usize

Returns the Phase 2 (Accept/Commit) quorum size under the current policy.

pub fn is_valid_phase2_quorum(&self, voters: &HashSet<&str>) -> bool

Returns true if voters satisfies the Phase 2 quorum requirement.

pub fn rebuild_quorum_system(&self) -> Result<(), String>

Validate and optionally rebuild the quorum system after a membership change. For SimpleMajority and Expression policies this is always valid; for Flexible it checks phase1 + phase2 > n.

Returns Err if the current policy is unsafe for the new group size.

pub fn quorum_size(&self) -> u32

Returns the phase-2 quorum size for the configured quorum policy.

This is a compatibility shim that returns phase2_quorum cast to u32. The result is policy-dependent: under the default Majority policy this is a simple majority of electable nodes, but under Flexible or Expression policies it may be larger or smaller than a simple majority. New code should call phase2_quorum directly.

pub fn contains_node(&self, name: &str) -> bool

Returns true if the group contains a node with the given name.

pub fn node_count(&self) -> usize

Returns the total number of nodes in the group.

Trait Implementations

impl Clone for RepGroup

fn clone(&self) -> RepGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RepGroup

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

Formats the value using the given formatter.

impl Display for RepGroup

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

Formats the value using the given formatter.