Struct EndToEndSyncManager 

pub struct EndToEndSyncManager<S, T>
where
    S: LocalStorage + Send + Sync + 'static,
    T: SyncTransport + Send + Sync + 'static,
{ /* private fields */ }

End-to-end synchronization manager

Implementations

impl<S, T> EndToEndSyncManager<S, T>

where S: LocalStorage + Send + Sync + 'static, T: SyncTransport + Send + Sync + 'static, EndToEndSyncError: From<<T as SyncTransport>::Error>,

pub fn new( replica_id: ReplicaId, storage: Arc<S>, transport: Arc<T>, sync_interval: Duration, heartbeat_interval: Duration, ) -> Self

Create a new end-to-end sync manager

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

Start the synchronization manager

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

Stop the synchronization manager

pub async fn add_collection( &self, metadata: CollectionMetadata, ) -> Result<(), EndToEndSyncError>

Add a collection to synchronize

pub async fn remove_collection( &self, collection_id: &str, ) -> Result<(), EndToEndSyncError>

Remove a collection from synchronization

pub async fn get_collection( &self, collection_id: &str, ) -> Result<Option<CollectionMetadata>, EndToEndSyncError>

Get collection metadata

pub async fn list_collections( &self, ) -> Result<Vec<CollectionMetadata>, EndToEndSyncError>

List all collections

pub async fn get_peer( &self, peer_id: &ReplicaId, ) -> Result<Option<PeerInfo>, EndToEndSyncError>

Get peer information

pub async fn list_peers(&self) -> Result<Vec<PeerInfo>, EndToEndSyncError>

List all peers

pub async fn get_sync_state(&self) -> SyncState

Get current sync state

pub async fn is_running(&self) -> bool

Check if the manager is running

Trait Implementations

impl<S, T> Clone for EndToEndSyncManager<S, T>

where S: LocalStorage + Send + Sync + 'static, T: SyncTransport + Send + Sync + 'static, EndToEndSyncError: From<<T as SyncTransport>::Error>,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.