Struct MongoIdempotencyStore 

pub struct MongoIdempotencyStore { /* private fields */ }

A MongoDB-backed IdempotencyStore.

Clone-cheap: holds only the collection handle (an Arc internally).

Implementations

impl MongoIdempotencyStore

pub fn new(db: &Database) -> Self

Wrap an existing database with the default 24-hour TTL.

pub fn with_collection(db: &Database, collection_name: &str) -> Self

Wrap an existing database using collection_name.

pub fn with_ttl_secs(self, ttl_secs: u64) -> Self

Set a custom TTL in seconds for idempotency keys.

pub async fn ensure_schema(&self) -> Result<(), DataError>

Create the TTL index on expires_at.

Must be called once (or at each startup — it is idempotent).

Trait Implementations

impl Clone for MongoIdempotencyStore

fn clone(&self) -> MongoIdempotencyStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl IdempotencyStore for MongoIdempotencyStore

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

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

Atomically claim key if it is free, otherwise report its current state.

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

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

Mark key’s operation completed and store response for future replays.

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

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

Fetch the raw record for key, if any.