Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

A single-process, in-memory LockBackend.

Fully functional: fencing tokens are strictly monotonic per key, and an expired lease is reclaimable by the next acquirer. This is the backend the deterministic simulation test exercises.

Implementations

impl InMemoryBackend

pub fn new() -> Self

Create an empty backend.

pub fn tracked_keys(&self) -> usize

Number of tracked keys (held or historically seen). Test helper.

Trait Implementations

impl Default for InMemoryBackend

fn default() -> Self

Returns the “default value” for a type.

impl LockBackend for InMemoryBackend

fn try_acquire<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<(u64, Instant)>> + Send + 'async_trait>>

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

Attempt to acquire key for ttl. On success returns the fencing token (strictly monotonic per key) and the local lease deadline.

fn try_renew<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, token: u64, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<Instant>> + Send + 'async_trait>>

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

Renew a lease previously acquired with token, extending it by ttl. Returns the new local lease deadline.

fn release<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, token: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Release a lease. A no-op if token is already stale (someone else owns the key), so releasing an expired guard is harmless.

fn name(&self) -> &'static str

Human-readable backend name, used in tracing spans and errors.