Struct SyncManager 

pub struct SyncManager<T: NetworkTransport> { /* private fields */ }

Manages synchronization between peers.

Implementations

impl<T: NetworkTransport> SyncManager<T>

pub fn new(transport: Arc<T>, config: SyncConfig) -> Self

Create a new sync manager for a transport and configuration.

pub fn config(&self) -> &SyncConfig

Return the active synchronization configuration.

pub async fn broadcast_update( &mut self, document_id: &str, delta: Vec<u8>, version: u64, ) -> Result<(), SdkError>

Broadcast a document update to all connected peers.

Errors

Returns SdkError::SyncError if the transport broadcast fails.

pub async fn request_sync( &mut self, peer_id: &PeerId, document_id: &str, version: u64, ) -> Result<(), SdkError>

Send a sync request to a specific peer.

Errors

Returns SdkError::SyncError if sending the request fails.

pub fn update_peer_state( &mut self, peer_id: &PeerId, document_id: &str, version: u64, )

Update local sync metadata for a peer/document pair.

pub fn get_peer_state(&self, peer_id: &PeerId) -> Option<&PeerSyncState>

Return sync metadata for a peer if present.