Struct GCounter 

pub struct GCounter { /* private fields */ }

A grow-only counter (G-Counter).

Each replica maintains its own count. The total value is the sum of all replica counts. This counter can only be incremented, never decremented.

Example

use crdt_kit::prelude::*;

let mut c1 = GCounter::new("node-1");
c1.increment();
c1.increment();

let mut c2 = GCounter::new("node-2");
c2.increment();

c1.merge(&c2);
assert_eq!(c1.value(), 3);

Implementations

impl GCounter

pub fn new(actor: impl Into<String>) -> Self

Create a new G-Counter for the given actor/replica ID.

pub fn increment(&mut self)

Increment this replica’s count by 1.

pub fn increment_by(&mut self, n: u64)

Increment this replica’s count by n.

pub fn value(&self) -> u64

Get the total counter value across all replicas.

pub fn actor(&self) -> &str

Get this replica’s actor ID.

pub fn count_for(&self, actor: &str) -> u64

Get the count for a specific actor.

Trait Implementations

impl Clone for GCounter

fn clone(&self) -> GCounter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Crdt for GCounter

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

Merge another replica’s state into this one.

impl Debug for GCounter

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

Formats the value using the given formatter.

impl PartialEq for GCounter

fn eq(&self, other: &GCounter) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for GCounter

impl StructuralPartialEq for GCounter