Struct GCounter 

pub struct GCounter { /* private fields */ }

A grow-only counter that supports distributed increment operations.

Each replica has a unique ID and maintains its own count. The total value is the sum across all replicas. Merging takes the maximum count for each replica ID.

Implementations

impl GCounter

pub fn new() -> Self

Create a new empty counter.

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 value(&self) -> u64

Get the current value (sum of all replica counts).

pub fn replica_id(&self) -> ReplicaId

Get the replica ID for this counter.

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

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

Formats the value using the given formatter.

impl Default for GCounter

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GCounter

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Merge for GCounter

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

Merge another counter into this one.

For each replica ID, takes the maximum count between the two counters. This ensures convergence: merging A into B or B into A yields the same result.

impl PartialEq<i32> for GCounter

Compare a GCounter directly to an i32 value.

Enables ergonomic conditionals with smaller integer types.

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<u64> for GCounter

Compare a GCounter directly to a u64 value.

Enables ergonomic conditionals like counter == 5 by comparing the counter’s aggregated value to the integer.

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

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 GCounter