Struct LocalFirstCollection 

pub struct LocalFirstCollection<T, Tr>
where
    T: Clone + Send + Sync + Serialize + for<'de> Deserialize<'de> + Mergeable + Default,
    Tr: SyncTransport + Clone + 'static,
{ /* private fields */ }

Local-first collection that can synchronize with remote peers

Implementations

impl<T, Tr> LocalFirstCollection<T, Tr>

where T: Clone + Send + Sync + Serialize + for<'de> Deserialize<'de> + Mergeable + Default, Tr: SyncTransport + Clone + 'static,

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

Create a new collection

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

Create a collection with a specific replica ID

pub fn replica_id(&self) -> ReplicaId

Get the replica ID for this collection

pub async fn insert(&self, key: &str, value: &T) -> Result<(), CollectionError>

Insert or update an item

pub async fn get(&self, key: &str) -> Result<Option<T>, CollectionError>

Get an item by key

pub async fn remove(&self, key: &str) -> Result<(), CollectionError>

Remove an item

pub async fn keys(&self) -> Result<Vec<String>, CollectionError>

Get all keys

pub async fn values(&self) -> Result<Vec<T>, CollectionError>

Get all values

pub async fn contains_key(&self, key: &str) -> Result<bool, CollectionError>

Check if a key exists

pub async fn len(&self) -> Result<usize, CollectionError>

Get the number of items

pub async fn is_empty(&self) -> Result<bool, CollectionError>

Check if the collection is empty

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

Start synchronization

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

Stop synchronization

pub async fn sync_state(&self) -> Result<SyncState, CollectionError>

Get synchronization state

pub async fn is_online(&self) -> Result<bool, CollectionError>

Check if online

pub async fn peer_count(&self) -> Result<usize, CollectionError>

Get peer count

pub fn set_auto_sync(&mut self, enabled: bool)

Set auto-sync mode

pub async fn force_sync(&self) -> Result<(), CollectionError>

Force synchronization

pub async fn insert_batch( &self, items: impl IntoIterator<Item = (String, T)>, ) -> Result<(), CollectionError>

Insert or update multiple items in a batch

pub async fn update_batch( &self, updates: impl IntoIterator<Item = (String, T)>, ) -> Result<(), CollectionError>

Update multiple items in a batch

pub async fn remove_batch( &self, keys: impl IntoIterator<Item = String>, ) -> Result<(), CollectionError>

Remove multiple items in a batch

pub async fn get_batch( &self, keys: impl IntoIterator<Item = String>, ) -> Result<Vec<(String, Option<T>)>, CollectionError>

Get multiple items by keys

pub async fn contains_keys( &self, keys: impl IntoIterator<Item = String>, ) -> Result<Vec<(String, bool)>, CollectionError>

Check if multiple keys exist

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

Get all peers

pub async fn sync_info(&self) -> Result<SyncInfo, CollectionError>

Get sync information