Struct InMemoryConsensusStorage 

pub struct InMemoryConsensusStorage<Scope>
where
    Scope: ConsensusScope,
{ /* private fields */ }

In-memory storage for consensus sessions.

Stores all sessions in RAM using a hash map. This is the default storage implementation and works well for testing or single-node setups. Data is lost when the process exits.

Implementations

impl<Scope> InMemoryConsensusStorage<Scope>

where Scope: ConsensusScope,

pub fn new() -> Self

Create a new in-memory storage instance.

This stores all consensus sessions in RAM. Perfect for testing or single-node setups, but data won’t persist across restarts.

Trait Implementations

impl<Scope> Clone for InMemoryConsensusStorage<Scope>

where Scope: ConsensusScope + Clone,

fn clone(&self) -> InMemoryConsensusStorage<Scope>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Scope> ConsensusStorage<Scope> for InMemoryConsensusStorage<Scope>

where Scope: ConsensusScope + Clone,

async fn save_session( &self, scope: &Scope, session: ConsensusSession, ) -> Result<(), ConsensusError>

Persist a session (insert or overwrite by proposal_id).

async fn get_session( &self, scope: &Scope, proposal_id: u32, ) -> Result<Option<ConsensusSession>, ConsensusError>

Retrieve a session by proposal ID, or None if it doesn’t exist.

async fn remove_session( &self, scope: &Scope, proposal_id: u32, ) -> Result<Option<ConsensusSession>, ConsensusError>

Remove and return a session, or None if not found.

async fn list_scope_sessions( &self, scope: &Scope, ) -> Result<Option<Vec<ConsensusSession>>, ConsensusError>

List all sessions in a scope, or None if the scope doesn’t exist.

fn stream_scope_sessions<'a>( &'a self, scope: &'a Scope, ) -> impl Stream<Item = Result<ConsensusSession, ConsensusError>> + Send + 'a

Stream sessions in a scope one at a time (useful for large scopes).

async fn replace_scope_sessions( &self, scope: &Scope, sessions_list: Vec<ConsensusSession>, ) -> Result<(), ConsensusError>

Replace all sessions in a scope atomically.

async fn list_scopes(&self) -> Result<Option<Vec<Scope>>, ConsensusError>

List all known scopes, or None if no scopes exist.

async fn update_session<R, F>( &self, scope: &Scope, proposal_id: u32, mutator: F, ) -> Result<R, ConsensusError>

where R: Send, F: FnOnce(&mut ConsensusSession) -> Result<R, ConsensusError> + Send,

Apply a mutation to a single session in place.

async fn update_scope_sessions<F>( &self, scope: &Scope, mutator: F, ) -> Result<(), ConsensusError>

where F: FnOnce(&mut Vec<ConsensusSession>) -> Result<(), ConsensusError> + Send,

Apply a mutation to all sessions in a scope (e.g. trimming old entries).

async fn get_scope_config( &self, scope: &Scope, ) -> Result<Option<ScopeConfig>, ConsensusError>

Get the scope-level configuration, or None if not yet initialized.

async fn set_scope_config( &self, scope: &Scope, config: ScopeConfig, ) -> Result<(), ConsensusError>

Set (insert or overwrite) the scope-level configuration.

async fn update_scope_config<F>( &self, scope: &Scope, updater: F, ) -> Result<(), ConsensusError>

where F: FnOnce(&mut ScopeConfig) -> Result<(), ConsensusError> + Send,

Apply a mutation to an existing scope configuration.

impl<Scope> Default for InMemoryConsensusStorage<Scope>

where Scope: ConsensusScope,

fn default() -> Self

Returns the “default value” for a type.