Struct ReplicaSet 

pub struct ReplicaSet {
    pub shard_id: String,
    pub replication_factor: u32,
    pub primary: Option<String>,
    pub replicas: HashMap<String, ReplicaInfo>,
    pub target_replicas: u32,
    pub version: u64,
}

Replica set for a shard/namespace

Fields

shard_id: String

Shard or namespace identifier

replication_factor: u32

Configured replication factor

primary: Option<String>

Primary replica node

replicas: HashMap<String, ReplicaInfo>

All replicas (including primary)

target_replicas: u32

Target replication factor (may differ during rebalancing)

version: u64

Version for optimistic concurrency

Implementations

impl ReplicaSet

pub fn new(shard_id: String, replication_factor: u32) -> Self

pub fn healthy_count(&self) -> usize

Get count of healthy replicas

pub fn in_sync_count(&self) -> usize

Get count of in-sync replicas

pub fn has_quorum(&self) -> bool

Check if replica set has quorum

pub fn can_write(&self, mode: WriteAckMode) -> bool

Check if replica set can accept writes

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

Get all in-sync replica node IDs

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

Get all healthy replica node IDs

Trait Implementations

impl Clone for ReplicaSet

fn clone(&self) -> ReplicaSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicaSet

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReplicaSet

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ReplicaSet

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

where __S: Serializer,

Serialize this value into the given Serde serializer.