Struct GroupCrdtInnerState 

pub struct GroupCrdtInnerState<ID, OP, M, C>
where
    ID: IdentityHandle,
    OP: OperationId + Ord,
{
    pub operations: HashMap<OP, M>,
    pub ignore: HashSet<OP>,
    pub mutual_removes: HashSet<OP>,
    pub states: HashMap<OP, HashMap<ID, GroupMembersState<GroupMember<ID>, C>>>,
    pub graph: DiGraphMap<OP, ()>,
}

Inner state object for GroupCrdt which contains the actual groups state, including operation graph and membership snapshots.

Fields

operations: HashMap<OP, M>

All operations processed by this group.

ignore: HashSet<OP>

All operations who’s actions should be ignored.

mutual_removes: HashSet<OP>

All operations which are part of a mutual remove cycle.

states: HashMap<OP, HashMap<ID, GroupMembersState<GroupMember<ID>, C>>>

All resolved states.

graph: DiGraphMap<OP, ()>

Operation graph of all auth operations.

Implementations

impl<ID, OP, M, C> GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle, OP: OperationId + Ord, M: Operation<ID, OP, C>, C: Conditions,

pub fn heads(&self) -> HashSet<OP>

Current tips for the groups operation graph.

pub fn heads_filtered(&self, groups: &[ID]) -> HashSet<OP>

Get graph tips filtered to only those which included “create” operation for passed group ids in their causal history.

pub fn current_state( &self, ) -> HashMap<ID, GroupMembersState<GroupMember<ID>, C>>

Current group states.

This method gets the state at all graph tips and then merges them together into one new state which represents the current state of the groups.

pub fn state_at( &self, dependencies: &HashSet<OP>, ) -> Result<HashMap<ID, GroupMembersState<GroupMember<ID>, C>>, GroupCrdtInnerError<OP>>

Get the state at a certain point in history.

pub fn members(&self, group_id: ID) -> Vec<(ID, Access<C>)>

Get all current individual members of a group.

pub fn groups(&self, group_id: ID) -> Vec<(ID, Access<C>)>

Get all current transitive groups inside a group.

pub fn traverse_members( &self, group_id: ID, depth: u32, ) -> Vec<(GroupMember<ID>, Access<C>)>

Traverse membership graph with a specified max. depth and return all visited members (individuals and transitive groups) of a group.

Set depth to 0 to traverse the full graph.

Trait Implementations

impl<ID, OP, M: Clone, C: Clone> Clone for GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle + Clone, OP: OperationId + Ord + Clone,

fn clone(&self) -> GroupCrdtInnerState<ID, OP, M, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ID, OP, M: Debug, C: Debug> Debug for GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle + Debug, OP: OperationId + Ord + Debug,

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

Formats the value using the given formatter.

impl<ID, OP, M, C> Default for GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle, OP: OperationId + Ord,

fn default() -> Self

Returns the “default value” for a type.

impl<'de, ID, OP, M, C> Deserialize<'de> for GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle + Deserialize<'de>, OP: OperationId + Ord + Deserialize<'de>, M: Deserialize<'de>, C: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<ID, OP, M, C> Serialize for GroupCrdtInnerState<ID, OP, M, C>

where ID: IdentityHandle + Serialize, OP: OperationId + Ord + Serialize, M: Serialize, C: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.