Struct CrdtStore 

pub struct CrdtStore { /* private fields */ }

A simple conflict-free replicated data store backed by a concurrent map.

Implementations

impl CrdtStore

pub fn put( &self, id: impl Into<NodeId>, actor: impl Into<ActorId>, data: NodeData, ) -> NodeId

Inserts or updates a node using CRDT semantics.

pub fn delete(&self, id: impl AsRef<str>) -> Result<(), StoreError>

Removes a node from the store.

pub fn get(&self, id: impl AsRef<str>) -> Option<NodeRecord>

Fetches a node by identifier.

pub fn list(&self) -> Vec<NodeRecord>

Lists all nodes currently stored.

pub fn apply(&self, op: CrdtOperation) -> Result<Option<NodeId>, StoreError>

Applies a CRDT operation, returning the resulting node identifier when relevant.

pub fn operation_for( &self, actor: impl Into<ActorId>, data: NodeData, ) -> (NodeId, CrdtOperation)

Generates a CRDT operation representing the provided node data.

Trait Implementations

impl Debug for CrdtStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CrdtStore

fn default() -> CrdtStore

Returns the “default value” for a type.