Struct MemoryIdempotencyStore 

pub struct MemoryIdempotencyStore { /* private fields */ }

In-memory idempotency cache.

Implementations

impl MemoryIdempotencyStore

pub fn new() -> Self

pub fn with_inflight_ttl(self, ttl: Duration) -> Self

Override the TTL used for in-flight begin entries. Default 300s. Set this to be at least as long as the slowest handler that may register an idempotency key — anything shorter risks an in-flight entry expiring before the handler completes, breaking coalescing.

Trait Implementations

impl Clone for MemoryIdempotencyStore

fn clone(&self) -> MemoryIdempotencyStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryIdempotencyStore

fn default() -> Self

Returns the “default value” for a type.

impl IdempotencyStore for MemoryIdempotencyStore

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

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

Reads an existing entry for key.

fn begin<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, payload_sig: [u8; 20], ) -> Pin<Box<dyn Future<Output = IdempotencyEntry> + Send + 'async_trait>>

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

Marks key as in-flight; returns the freshly inserted record, or the existing one if another request arrived first.

fn complete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, entry: IdempotencyEntry, ttl: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Persists a completed entry with the configured TTL.

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

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

Removes the entry — typically invoked when the handler decided not to cache the result (e.g. opt-out via response header).