Struct InMemoryConfirmationStore 

pub struct InMemoryConfirmationStore { /* private fields */ }

In-memory confirmation store backed by a DashMap.

Each entry carries an AbortHandle for its TTL expiry task, so confirming or rejecting an action immediately cancels the background timer.

Concurrency

DashMap guards are never held across .await points. In list_pending, the entries are collected into a Vec while holding the shard locks, and the guard is dropped before returning.

Implementations

impl InMemoryConfirmationStore

pub fn new() -> Self

Create a new store.

Trait Implementations

impl ConfirmationStore for InMemoryConfirmationStore

fn request_confirmation<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, payload: Value, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Store a payload under the given key, replacing any existing entry.

fn confirm<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, Error>> + Send + 'async_trait>>

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

Confirm the action identified by key.

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

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

Reject the action identified by key.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, Error>> + Send + 'async_trait>>

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

Retrieve the stored payload without removing the entry.

fn list_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PendingActionInfo>, Error>> + Send + 'async_trait>>

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

List all pending (not yet confirmed, rejected, or expired) entries.

impl Default for InMemoryConfirmationStore

fn default() -> Self

Returns the “default value” for a type.