Struct InMemoryTokenStore 

pub struct InMemoryTokenStore { /* private fields */ }

Simple in-memory token store. Thread-safe via Mutex.

Suitable for tests and single-node deployments. Does not survive process restart — a previously-consumed token is invisible after restart, allowing replay on that edge case. Production deployments must use a Raft-backed backend.

Implementations

impl InMemoryTokenStore

pub fn new() -> Self

Trait Implementations

impl Clone for InMemoryTokenStore

fn clone(&self) -> InMemoryTokenStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryTokenStore

fn default() -> InMemoryTokenStore

Returns the “default value” for a type.

impl TokenStateBackend for InMemoryTokenStore

fn register<'life0, 'async_trait>( &'life0 self, state: JoinTokenState, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register a freshly issued token with Issued state.

fn begin_inflight<'life0, 'life1, 'async_trait>( &'life0 self, token_hash: &'life1 [u8; 32], node_addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<(), TokenStateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Attempt to transition from Issued → InFlight. Returns Err(AlreadyConsumed) / Err(Expired) / Err(Aborted) if the token is already in a terminal or conflicting state.

fn mark_consumed<'life0, 'life1, 'async_trait>( &'life0 self, token_hash: &'life1 [u8; 32], node_addr: SocketAddr, ts_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<(), TokenStateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Transition from InFlight → Consumed. Called after the bundle has been sent and the peer has acknowledged receipt.

fn revert_inflight<'life0, 'life1, 'async_trait>( &'life0 self, token_hash: &'life1 [u8; 32], ) -> Pin<Box<dyn Future<Output = Result<(), TokenStateError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Revert InFlight → Issued (joiner timed out before ACK).

fn get(&self, token_hash: &[u8; 32]) -> Option<JoinTokenState>

Look up the current state.