Struct PNCounter 

pub struct PNCounter { /* private fields */ }

A positive-negative counter (PN-Counter).

Supports both increment and decrement operations by maintaining two internal G-Counters: one for increments and one for decrements. The value is increments - decrements.

Example

use crdt_kit::prelude::*;

let mut c1 = PNCounter::new("node-1");
c1.increment();
c1.increment();
c1.decrement();
assert_eq!(c1.value(), 1);

let mut c2 = PNCounter::new("node-2");
c2.decrement();

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

Implementations

impl PNCounter

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

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

pub fn increment(&mut self)

Increment the counter by 1.

pub fn decrement(&mut self)

Decrement the counter by 1.

pub fn value(&self) -> i64

Get the current counter value (increments - decrements).

Trait Implementations

impl Clone for PNCounter

fn clone(&self) -> PNCounter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Crdt for PNCounter

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

Merge another replica’s state into this one.

impl Debug for PNCounter

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

Formats the value using the given formatter.

impl PartialEq for PNCounter

fn eq(&self, other: &PNCounter) -> 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 PNCounter

impl StructuralPartialEq for PNCounter