Struct InMemoryIdemStore 

pub struct InMemoryIdemStore { /* private fields */ }

Simple in-memory store used in tests or when JetStream is unavailable.

Implementations

impl InMemoryIdemStore

pub fn new() -> Self

pub async fn purge_expired(&self, now: OffsetDateTime)

Trait Implementations

impl Clone for InMemoryIdemStore

fn clone(&self) -> InMemoryIdemStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryIdemStore

fn default() -> InMemoryIdemStore

Returns the “default value” for a type.

impl IdemStore for InMemoryIdemStore

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

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

Attempts to register key with the provided TTL. Returns Ok(true) when the key did not previously exist (meaning the caller should continue processing), Ok(false) for a duplicate, or an error when the store was unavailable.