Struct SyncEngine 

pub struct SyncEngine<Tr>
where
    Tr: SyncTransport + Clone,
{ /* private fields */ }

Enhanced synchronization manager

Implementations

impl<Tr> SyncEngine<Tr>

where Tr: SyncTransport + Clone + 'static,

pub fn new(storage: Storage, transport: Tr) -> Self

pub fn with_replica_id( storage: Storage, transport: Tr, replica_id: ReplicaId, ) -> Self

pub async fn state(&self) -> SyncState

pub fn replica_id(&self) -> ReplicaId

pub async fn is_online(&self) -> bool

pub async fn peer_count(&self) -> usize

pub async fn start_sync(&mut self) -> Result<(), SyncEngineError>

Start the synchronization process

pub async fn stop_sync(&mut self) -> Result<(), SyncEngineError>

Stop the synchronization process

pub async fn sync<V>( &mut self, key: &str, value: &V, ) -> Result<(), SyncEngineError>

where V: Mergeable + Serialize + Send + Sync + Clone,

Sync a CRDT value with peers

pub async fn process_messages(&mut self) -> Result<(), SyncEngineError>

Process incoming messages

pub async fn peers(&self) -> impl Iterator<Item = (ReplicaId, PeerInfo)>

Get all peers