Struct AntiEntropyCluster 

pub struct AntiEntropyCluster<S: Lattice + Clone> {
    replicas: Vec<DeltaReplica<S, S>>,
    network: NetworkSimulator<S>,
}

Anti-entropy coordinator for a cluster of replicas

Fields

replicas: Vec<DeltaReplica<S, S>>

All replicas in the cluster

network: NetworkSimulator<S>

Network simulator

Implementations

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

pub fn new(n: usize, config: NetworkConfig) -> Self

Create a new cluster with n replicas

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

Get replica by index

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

Get mutable replica by index

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

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

Perform a mutation on a specific replica

pub fn initiate_sync(&mut self, from_idx: usize, to_idx: usize)

Initiate sync from one replica to another

pub fn process_one(&mut self) -> bool

Process one network message

pub fn drain_network(&mut self)

Run until network is empty

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

Broadcast delta from one replica to all others

pub fn full_sync_round(&mut self)

Full sync: every replica syncs with every other replica

pub fn is_converged(&self) -> bool

Check if all replicas have converged

pub fn retransmit_and_process(&mut self)

Retransmit lost messages and process

pub fn len(&self) -> usize

Get number of replicas

pub fn is_empty(&self) -> bool

Check if cluster is empty

Trait Implementations

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

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

Formats the value using the given formatter.