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.

Uses the default MemoryBackend (no persistence). For durable storage across restarts, use new_with_backend.

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 fn new_with_backend<N: NetworkProvider + 'static>( node: Arc<Node<N>>, store_id: &str, backend: Arc<dyn StoreBackend>, ) -> Arc<Self>

Create a new SyncedStore with a custom persistence backend.

On startup, attempts to load the local device’s persisted slice. If found, the in-memory state and version counter are restored so the store picks up where it left off.

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

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

Rapid successive calls coalesce on the wire: peers are guaranteed to observe the newest version, not every intermediate one (the store is last-write-wins state, not an event log).

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.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.