Struct ReplicaSet 

pub struct ReplicaSet { /* private fields */ }

Manages a set of replicas

Implementations

impl ReplicaSet

pub fn new(cluster_id: impl Into<String>) -> Self

Create a new replica set

pub fn add_replica( &mut self, id: impl Into<String>, address: impl Into<String>, role: ReplicaRole, ) -> Result<()>

Add a replica to the set

pub fn remove_replica(&mut self, id: &str) -> Result<()>

Remove a replica from the set

pub fn get_replica(&self, id: &str) -> Option<Replica>

Get a replica by ID

pub fn get_primary(&self) -> Option<Replica>

Get the current primary replica

pub fn get_secondaries(&self) -> Vec<Replica>

Get all secondary replicas

pub fn get_healthy_replicas(&self) -> Vec<Replica>

Get all healthy replicas

pub fn promote_to_primary(&mut self, id: &str) -> Result<()>

Promote a secondary to primary

pub fn demote_to_secondary(&mut self, id: &str) -> Result<()>

Demote a primary to secondary

pub fn has_quorum(&self) -> bool

Check if quorum is available

pub fn get_quorum_size(&self) -> usize

Get the required quorum size

pub fn set_quorum_size(&self, size: usize)

Set the quorum size

pub fn replica_ids(&self) -> Vec<String>

Get all replica IDs

pub fn replica_count(&self) -> usize

Get replica count

pub fn cluster_id(&self) -> &str

Get the cluster ID