Struct SyncManager 

pub struct SyncManager<S, T>
where
    S: LocalStorage,
    T: SyncTransport,
{ /* private fields */ }

Legacy synchronization manager (for backward compatibility)

Implementations

impl<S, T> SyncManager<S, T>

where S: LocalStorage, T: SyncTransport,

pub fn new(storage: S, transport: T) -> Self

pub fn with_replica_id(storage: S, transport: T, replica_id: ReplicaId) -> Self

pub fn state(&self) -> &SyncState

pub fn replica_id(&self) -> ReplicaId

pub fn is_online(&self) -> bool

pub fn peer_count(&self) -> usize

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

where V: Mergeable + Serialize + Send + Sync + Clone, V::Error: Into<SyncError>,

Sync a CRDT value with peers

pub async fn process_messages<V>( &mut self, ) -> Result<Vec<(String, V)>, SyncError>

where V: Mergeable + Serialize + for<'de> Deserialize<'de> + Clone + Send + Sync, V::Error: Into<SyncError>,

Process incoming sync messages

pub async fn announce_presence(&mut self) -> Result<(), SyncError>

Announce presence to peers

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

Get all peers