Struct InMemoryGroupStateStorage

pub struct InMemoryGroupStateStorage { /* private fields */ }

In memory group state storage backed by a HashMap.

All clones of an instance of this type share the same underlying HashMap.

Implementations

impl InMemoryGroupStateStorage

pub fn new() -> Self

Create an empty group state storage.

pub fn with_max_epoch_retention( self, max_epoch_retention: usize, ) -> Result<Self, MlsError>

pub fn stored_groups(&self) -> Vec<Vec<u8>>

Get the set of unique group ids that have data stored.

pub fn delete_group(&self, group_id: &[u8])

Delete all data corresponding to group_id.

Trait Implementations

impl Clone for InMemoryGroupStateStorage

fn clone(&self) -> InMemoryGroupStateStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryGroupStateStorage

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

Formats the value using the given formatter.

impl Default for InMemoryGroupStateStorage

fn default() -> Self

Returns the “default value” for a type.

impl GroupStateStorage for InMemoryGroupStateStorage

type Error = Infallible

fn max_epoch_id(&self, group_id: &[u8]) -> Result<Option<u64>, Self::Error>

The EpochRecord::id value that is associated with a stored prior epoch for a particular group.

fn state(&self, group_id: &[u8]) -> Result<Option<Vec<u8>>, Self::Error>

Fetch a group state from storage.

fn epoch( &self, group_id: &[u8], epoch_id: u64, ) -> Result<Option<Vec<u8>>, Self::Error>

Lazy load cached epoch data from a particular group.

fn write( &mut self, state: GroupState, epoch_inserts: Vec<EpochRecord>, epoch_updates: Vec<EpochRecord>, ) -> Result<(), Self::Error>

Write pending state updates.