Struct ClusterSync 

pub struct ClusterSync { /* private fields */ }

One replica’s view of the cluster: the store, what it applied last, and operations waiting for the store to come back.

Implementations

impl ClusterSync

pub fn new( store: Box<dyn Store>, local: Box<dyn Local>, node: &str, ) -> ClusterSync

pub fn publish(&self, op: Op)

Send a change made here (already applied locally).

pub fn tick(&self, heartbeat: bool)

One round: send what’s pending, read the document, apply a newer one. heartbeat also writes this node’s heartbeat.

pub fn status_json(&self) -> String

{"node":…,"redis":"up"|"down","version":N,"nodes":[…],"pending":N}.