Struct Counter 

pub struct Counter { /* private fields */ }

PN-Counter CRDT (signed). See the module docs for semantics.

Implementations

impl Counter

pub fn new(replica: ReplicaId) -> Self

Create a counter at zero 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 value(&self) -> i128

Current signed value.

pub fn positive_total(&self) -> u128

Sum of all positive contributions across all replicas.

pub fn negative_total(&self) -> u128

Sum of all negative contributions across all replicas.

pub fn add(&mut self, delta: i64) -> CounterOp

Apply a signed delta to this replica. Returns the generated op.

pub fn increment(&mut self, by: u64) -> CounterOp

Increment by an unsigned amount.

pub fn decrement(&mut self, by: u64) -> CounterOp

Decrement by an unsigned amount.

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

Apply a remote op. Idempotent.

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

Merge all ops from other we haven’t seen.

pub fn ops(&self) -> &[CounterOp]

All ops in this counter’s log.

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

Iterate over ops not yet seen by since.

pub fn version(&self) -> &VersionVector

This replica’s current version vector.

Trait Implementations

impl Clone for Counter

fn clone(&self) -> Counter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Counter

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

Formats the value using the given formatter.

impl Default for Counter

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Counter

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Counter

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.