Struct MemoryApprovalStore 

pub struct MemoryApprovalStore { /* private fields */ }

An in-process ApprovalStore. Cloning shares the state, so two coordinators over clones model two threads (or, with a fresh coordinator over the same store, a restart that kept the durable half). A real restart of the process forgets everything.

Implementations

impl MemoryApprovalStore

pub fn new() -> Self

Trait Implementations

impl ApprovalStore for MemoryApprovalStore

fn insert(&self, record: &ApprovalRecord) -> Result<(), StoreError>

Store a new request. Err(Exists) when the id is taken.

fn get(&self, id: &str) -> Result<Option<ApprovalRecord>, StoreError>

fn replace( &self, expected_revision: u64, record: &ApprovalRecord, ) -> Result<(), StoreError>

Replace the stored record with record only if the stored revision equals expected_revision; Err(Conflict) otherwise, Err(NotFound) for an unknown id.

fn list( &self, states: &[ApprovalState], ) -> Result<Vec<ApprovalRecord>, StoreError>

Every record in one of states, oldest first.

fn claim_nonce( &self, value: &str, expires_ms: u64, now_ms: u64, ) -> Result<bool, StoreError>

Remember value until expires_ms. Ok(true) when it was new, Ok(false) when it was already remembered (a replay). now_ms lets the store forget expired nonces.

impl Clone for MemoryApprovalStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryApprovalStore

fn default() -> Self

Returns the “default value” for a type.