Struct RealtimeSyncManager 

pub struct RealtimeSyncManager<Tr>
where
    Tr: SyncTransport + Clone + Send + Sync + 'static,
{ /* private fields */ }

Real-time synchronization manager

Implementations

impl<Tr> RealtimeSyncManager<Tr>

where Tr: SyncTransport + Clone + Send + Sync + 'static,

pub fn new(replica_id: ReplicaId, transport: Tr, storage: Arc<Storage>) -> Self

pub async fn start(&mut self) -> Result<(), RealtimeSyncError>

Start real-time synchronization

pub async fn stop(&mut self) -> Result<(), RealtimeSyncError>

Stop real-time synchronization

pub async fn subscribe( &self, event_types: Vec<String>, callback: Box<dyn Fn(RealtimeEvent) + Send + Sync>, ) -> Result<String, RealtimeSyncError>

Subscribe to real-time events

pub async fn unsubscribe( &self, subscription_id: &str, ) -> Result<(), RealtimeSyncError>

Unsubscribe from real-time events

pub async fn broadcast_change<T: Mergeable + Serialize + Clone>( &self, key: &str, value: &T, change_type: ChangeType, ) -> Result<(), RealtimeSyncError>

Broadcast a change to all connected peers

pub async fn process_incoming_changes( &mut self, ) -> Result<usize, RealtimeSyncError>

Process incoming changes from peers

pub async fn get_sync_state(&self) -> SyncState

Get current synchronization state

pub async fn get_active_users(&self) -> HashMap<ReplicaId, UserInfo>

Get active users