Struct SyncState 

pub struct SyncState {
    pub node_id: Uuid,
    pub clock: VectorClock,
    pub peers: HashMap<Uuid, PeerState>,
    pub config: SyncConfig,
    /* private fields */
}

The synchronization state for a node.

Fields

node_id: Uuid

This node’s ID

clock: VectorClock

Current vector clock

peers: HashMap<Uuid, PeerState>

Known peers

config: SyncConfig

Configuration

Implementations

impl SyncState

pub fn new(node_id: Uuid) -> Self

Create a new sync state for a node.

pub fn with_config(node_id: Uuid, config: SyncConfig) -> Self

Create with custom configuration.

pub fn register_peer(&mut self, peer_id: Uuid, clock: VectorClock)

Register a new peer.

pub fn register_peer_with_info(&mut self, info: PeerInfo, clock: VectorClock)

Register a peer with full info.

pub fn remove_peer(&mut self, peer_id: &Uuid)

Remove a peer.

pub fn get_peer(&self, peer_id: &Uuid) -> Option<&PeerState>

Get a peer’s state.

pub fn get_peer_mut(&mut self, peer_id: &Uuid) -> Option<&mut PeerState>

Get a mutable reference to a peer’s state.

pub fn tick(&mut self) -> u64

Update our clock and get next message ID.

pub fn create_hello(&mut self, name: Option<String>) -> SyncMessage

Create a hello message.

pub fn create_delta_request(&mut self, since_clock: VectorClock) -> SyncMessage

Create a delta request message.

pub fn create_delta_response( &mut self, deltas: DeltaBatch, has_more: bool, ) -> SyncMessage

Create a delta response message.

pub fn create_full_state(&mut self, state: GA3) -> SyncMessage

Create a full state message.

pub fn create_heartbeat(&mut self) -> SyncMessage

Create a heartbeat message.

pub fn create_ack(&mut self, message_id: u64) -> SyncMessage

Create an acknowledgment message.

pub fn create_goodbye(&mut self) -> SyncMessage

Create a goodbye message.

pub fn handle_message(&mut self, message: &SyncMessage) -> Option<SyncMessage>

Handle an incoming message from a peer.

pub fn stale_peers(&self) -> Vec<Uuid>

Get list of stale peers that should be checked.

pub fn peers_needing_heartbeat(&self) -> Vec<Uuid>

Get peers that need heartbeats.

Trait Implementations

impl Debug for SyncState

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

Formats the value using the given formatter.