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>

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

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

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

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

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

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

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,

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

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

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

Get scope configuration (defaults for proposals in this scope)

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

Set scope configuration

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

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

Update scope configuration

impl<Scope> Default for InMemoryConsensusStorage<Scope>

where Scope: ConsensusScope,

fn default() -> Self

Returns the “default value” for a type.