Struct mls_rs::storage_provider::in_memory::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 copy 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 = Error

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<T>(&self, group_id: &[u8]) -> Result<Option<T>, Self::Error>

where T: GroupState + MlsDecode,

Fetch a group state from storage.

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

where T: EpochRecord + MlsEncode + MlsDecode,

Lazy load cached epoch data from a particular group.

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

where ST: GroupState + MlsEncode + MlsDecode + Send + Sync, ET: EpochRecord + MlsEncode + MlsDecode + Send + Sync,

Write pending state updates.