Struct CausalCluster 

pub struct CausalCluster<S: Lattice + Clone> {
    replicas: Vec<CausalReplica<S>>,
    network: CausalNetworkSimulator<S>,
}

Cluster coordinator for causal anti-entropy

Fields

replicas: Vec<CausalReplica<S>>

All replicas

network: CausalNetworkSimulator<S>

Network simulator

Implementations

impl<S: Lattice + Clone> CausalCluster<S>

pub fn new(n: usize, loss_rate: f64) -> Self

Create a new cluster with n replicas

pub fn replica(&self, idx: usize) -> &CausalReplica<S>

Get replica by index

pub fn replica_mut(&mut self, idx: usize) -> &mut CausalReplica<S>

Get mutable replica

pub fn mutate<F>(&mut self, replica_idx: usize, mutator: F) -> S

where F: FnOnce(&S) -> S,

Perform a mutation

pub fn broadcast_intervals(&mut self, from_idx: usize)

Initiate sync from one replica to all its peers

pub fn process_one(&mut self) -> bool

Process one network message

pub fn drain_network(&mut self)

Drain all messages

pub fn full_sync_round(&mut self)

Full sync round

pub fn is_converged(&self) -> bool

Check if converged

pub fn retransmit_and_process(&mut self)

Retransmit and process

pub fn len(&self) -> usize

Number of replicas

pub fn is_empty(&self) -> bool

Check if empty

pub fn crash_and_recover(&mut self, idx: usize)

Simulate a crash and recovery for a replica

pub fn total_pending(&self) -> usize

Get total pending out-of-order intervals across all replicas

Trait Implementations

impl<S: Debug + Lattice + Clone> Debug for CausalCluster<S>

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

Formats the value using the given formatter.