Struct crdts::gcounter::GCounter [−][src]
pub struct GCounter<A: Ord> { /* fields omitted */ }
GCounter
is a grow-only witnessed counter.
Examples
use crdts::{GCounter, CmRDT}; let mut a = GCounter::new(); let mut b = GCounter::new(); a.apply(a.inc("A")); b.apply(b.inc("B")); assert_eq!(a.read(), b.read()); a.apply(a.inc("A")); assert!(a.read() > b.read());
Implementations
impl<A: Ord + Clone> GCounter<A>
[src]
pub fn new() -> Self
[src]
Produce a new GCounter
.
pub fn inc(&self, actor: A) -> Dot<A>
[src]
Generate Op to increment the counter.
pub fn inc_many(&self, actor: A, steps: u64) -> Dot<A>
[src]
Generate Op to increment the counter by a number of steps.
pub fn read(&self) -> BigUint
[src]
Return the current sum of this counter.
Trait Implementations
impl<A: Clone + Ord> Clone for GCounter<A>
[src]
impl<A: Ord + Clone + Debug> CmRDT for GCounter<A>
[src]
type Op = Dot<A>
Op defines a mutation to the CRDT. As long as Op’s from one actor are replayed in exactly the same order they were generated by that actor, the CRDT will converge. In other words, we must have a total ordering on each actors operations, while requiring only a partial order over all ops. E.g. Read more
type Validation = Infallible
The validation error returned by validate_op
.
fn validate_op(&self, _op: &Self::Op) -> Result<(), Self::Validation>
[src]
fn apply(&mut self, op: Self::Op)
[src]
impl<A: Ord + Clone + Debug> CvRDT for GCounter<A>
[src]
type Validation = Infallible
The validation error returned by validate_merge
.
fn validate_merge(&self, _other: &Self) -> Result<(), Self::Validation>
[src]
fn merge(&mut self, other: Self)
[src]
impl<A: Debug + Ord> Debug for GCounter<A>
[src]
impl<A: Ord> Default for GCounter<A>
[src]
impl<'de, A: Ord> Deserialize<'de> for GCounter<A> where
A: Deserialize<'de>,
[src]
A: Deserialize<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl<A: Eq + Ord> Eq for GCounter<A>
[src]
impl<A: Hash + Ord> Hash for GCounter<A>
[src]
fn hash<__H: Hasher>(&self, state: &mut __H)
[src]
pub fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher,
1.3.0[src]
H: Hasher,
impl<A: PartialEq + Ord> PartialEq<GCounter<A>> for GCounter<A>
[src]
impl<A: Ord> ResetRemove<A> for GCounter<A>
[src]
fn reset_remove(&mut self, clock: &VClock<A>)
[src]
impl<A: Ord> Serialize for GCounter<A> where
A: Serialize,
[src]
A: Serialize,
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl<A: Ord> StructuralEq for GCounter<A>
[src]
impl<A: Ord> StructuralPartialEq for GCounter<A>
[src]
Auto Trait Implementations
impl<A> RefUnwindSafe for GCounter<A> where
A: RefUnwindSafe,
A: RefUnwindSafe,
impl<A> Send for GCounter<A> where
A: Send,
A: Send,
impl<A> Sync for GCounter<A> where
A: Sync,
A: Sync,
impl<A> Unpin for GCounter<A>
impl<A> UnwindSafe for GCounter<A> where
A: RefUnwindSafe,
A: RefUnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<A, T> Val<A> for T where
A: Ord,
T: Clone + Default + ResetRemove<A> + CmRDT,
[src]
A: Ord,
T: Clone + Default + ResetRemove<A> + CmRDT,