Struct Map 

pub struct Map<K: Eq + Hash + Clone, V: Clone> { /* private fields */ }

LWW-Map CRDT. See the module docs for semantics.

Implementations

impl<K: Eq + Hash + Clone, V: Clone> Map<K, V>

pub fn new(replica: ReplicaId) -> Self

Create an empty map for the given replica.

pub fn new_random() -> Self

Create a new instance with a random ReplicaId from OS entropy. See crate::new_replica_id.

pub fn replica_id(&self) -> ReplicaId

This replica’s id.

pub fn len(&self) -> usize

Number of visible (non-tombstoned) entries.

pub fn is_empty(&self) -> bool

Are there any visible entries?

pub fn get(&self, key: &K) -> Option<&V>

Look up the value for key, or None if absent / tombstoned.

pub fn iter(&self) -> impl Iterator<Item = (&K, &V)> + '_

Iterate visible (key, value) pairs.

pub fn keys(&self) -> impl Iterator<Item = &K> + '_

Iterate visible keys.

pub fn values(&self) -> impl Iterator<Item = &V> + '_

Iterate visible values.

pub fn contains_key(&self, key: &K) -> bool

Does the map contain key?

pub fn set(&mut self, key: K, value: V) -> MapOp<K, V>

Set key to value. Returns the generated MapOp.

pub fn remove(&mut self, key: K) -> MapOp<K, V>

Remove key. Always emits an op (even if the key was absent), so the remove can be replicated.

pub fn apply(&mut self, op: MapOp<K, V>) -> Result<(), Error>

Apply a remote operation. Idempotent.

pub fn merge(&mut self, other: &Self)

Merge all of other’s state into self. Equivalent to applying every op in other.log that we haven’t seen, in OpId order.

pub fn ops(&self) -> &[MapOp<K, V>]

All ops observed by this replica, in observation order.

pub fn ops_since<'a>( &'a self, since: &'a VersionVector, ) -> impl Iterator<Item = &'a MapOp<K, V>> + 'a

Iterate over ops not yet seen by since.

pub fn version(&self) -> &VersionVector

This replica’s current version vector.

Trait Implementations

impl<K: Clone + Eq + Hash + Clone, V: Clone + Clone> Clone for Map<K, V>

fn clone(&self) -> Map<K, V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Debug + Eq + Hash + Clone, V: Debug + Clone> Debug for Map<K, V>

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

Formats the value using the given formatter.

impl<K: Eq + Hash + Clone, V: Clone> Default for Map<K, V>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, K, V> Deserialize<'de> for Map<K, V>

where K: Eq + Hash + Clone + Deserialize<'de>, V: Clone + Deserialize<'de>,

Available on crate feature serde only.

fn deserialize<D: Deserializer<'de>>(de: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl<K, V> Serialize for Map<K, V>

where K: Eq + Hash + Clone + Serialize, V: Clone + Serialize,

Available on crate feature serde only.

fn serialize<S: Serializer>(&self, ser: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.