Struct PNCounter 

pub struct PNCounter { /* private fields */ }

A counter that can be incremented and decremented.

The value is the difference between total increments and total decrements. Each replica maintains its own increment and decrement counts.

Implementations

impl PNCounter

pub fn new() -> Self

Create a new counter with a random replica ID.

pub fn with_replica_id(id: ReplicaId) -> Self

Create a counter with a specific replica ID.

pub fn increment(&mut self, amount: u64)

Increment the counter by the given amount.

pub fn decrement(&mut self, amount: u64)

Decrement the counter by the given amount.

pub fn value(&self) -> i64

Get the current value (increments - decrements).

pub fn replica_id(&self) -> ReplicaId

Get the replica ID for this counter.

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 Debug for PNCounter

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

Formats the value using the given formatter.

impl Default for PNCounter

fn default() -> Self

Returns the “default value” for a type.

impl DeltaCrdt for PNCounter

type Delta = PNCounterDelta

The type of delta this CRDT produces.

fn delta_since(&self, since: &VClock) -> Option<Self::Delta>

Extract a delta containing changes since the given version.

fn apply_delta(&mut self, delta: &Self::Delta)

Apply an incoming delta to this CRDT.

fn version(&self) -> VClock

Get the current version (vector clock) of this CRDT.

impl<'de> Deserialize<'de> for PNCounter

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Merge for PNCounter

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

Merge another counter into this one.

For each replica ID, takes the maximum increment and decrement counts.

impl PartialEq<i32> for PNCounter

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

Allow comparing PNCounter to integers for ergonomic conditionals

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PNCounter