Struct SyncedStore 

pub struct SyncedStore<T> { /* private fields */ }

A synchronized key-value store with device-owned slices.

Each device owns one slice of type T. Writes update only the local slice and broadcast the change. Remote slices are received and cached automatically.

Created via SyncedStore::new or Node::synced_store.

Implementations

impl<T: Serialize + DeserializeOwned + Clone + Send + Sync + 'static> SyncedStore<T>

pub fn new<N: NetworkProvider + 'static>( node: Arc<Node<N>>, store_id: &str, ) -> Arc<Self>

Create a new SyncedStore and start the background sync task.

The store syncs on namespace "ss:{store_id}". The caller must hold an Arc<Node<N>> because the background task needs to outlive this constructor call.

pub async fn set(&self, data: T)

Update this device’s data. Increments version and broadcasts.

pub async fn local(&self) -> Option<T>

This device’s current data, or None if set() hasn’t been called.

pub async fn get(&self, device_id: &str) -> Option<Slice<T>>

A specific peer’s slice, or None if we haven’t received their data.

pub async fn all(&self) -> HashMap<String, Slice<T>>

All slices (local + remote).

pub async fn device_ids(&self) -> Vec<String>

Device IDs that have data in this store (local + remote).

pub fn subscribe(&self) -> Receiver<StoreEvent<T>>

Subscribe to store change events.

pub fn store_id(&self) -> &str

The store identifier.

pub fn device_id(&self) -> &str

This device’s ID.

pub fn version(&self) -> u64

Current local version number.

pub async fn stop(&self)

Stop the background sync task.

Trait Implementations

impl<T> Drop for SyncedStore<T>

fn drop(&mut self)

Executes the destructor for this type.