Struct crdts::orswot::Orswot

pub struct Orswot<M: Member, A: Actor> { /* fields omitted */ }

Orswot is an add-biased or-set without tombstones ported from the riak_dt CRDT library.

Implementations

impl<M: Member, A: Actor> Orswot<M, A>

pub fn new() -> Self

Returns a new Orswot instance.

pub fn clock(&self) -> VClock<A>

Return a snapshot of the ORSWOT clock

pub fn add(&self, member: M, ctx: AddCtx<A>) -> Op<M, A>

Add a single element.

pub fn add_all<I: IntoIterator<Item = M>>(
    &self,
    members: I,
    ctx: AddCtx<A>
) -> Op<M, A>

Add multiple elements.

pub fn rm(&self, member: M, ctx: RmCtx<A>) -> Op<M, A>

Remove a member with a witnessing ctx.

pub fn rm_all<I: IntoIterator<Item = M>>(
    &self,
    members: I,
    ctx: RmCtx<A>
) -> Op<M, A>

Remove members with a witnessing ctx.

pub fn contains(&self, member: &M) -> ReadCtx<bool, A>

Check if the set contains a member

pub fn read(&self) -> ReadCtx<HashSet<M>, A>

Retrieve the current members.

pub fn read_ctx(&self) -> ReadCtx<(), A>

Retrieve the current read context

Trait Implementations

impl<M: Member, A: Actor> Causal<A> for Orswot<M, A>

fn forget(&mut self, clock: &VClock<A>)

Forget data that is strictly smaller than this clock

impl<M: Clone + Member, A: Clone + Actor> Clone for Orswot<M, A>

fn clone(&self) -> Orswot<M, A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M: Member, A: Actor> CmRDT for Orswot<M, A>

type Op = Op<M, 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.

fn apply(&mut self, op: Self::Op)

Apply an Op to the CRDT

impl<M: Member, A: Actor> CvRDT for Orswot<M, A>

fn merge(&mut self, other: Self)

Merge combines another Orswot with this one.

impl<M: Debug + Member, A: Debug + Actor> Debug for Orswot<M, A>

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

Formats the value using the given formatter.

impl<M: Member, A: Actor> Default for Orswot<M, A>

fn default() -> Self

Returns the "default value" for a type.

impl<'de, M: Member, A: Actor> Deserialize<'de> for Orswot<M, A> where
    M: Deserialize<'de>,
    A: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<M: Eq + Member, A: Eq + Actor> Eq for Orswot<M, A>

impl<M: PartialEq + Member, A: PartialEq + Actor> PartialEq<Orswot<M, A>> for Orswot<M, A>

fn eq(&self, other: &Orswot<M, A>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Orswot<M, A>) -> bool

This method tests for !=.

impl<M: Member, A: Actor> Serialize for Orswot<M, A> where
    M: Serialize,
    A: Serialize, 

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

Serialize this value into the given Serde serializer.

impl<M: Member, A: Actor> StructuralEq for Orswot<M, A>

impl<M: Member, A: Actor> StructuralPartialEq for Orswot<M, A>