Struct MemoryStorage

pub struct MemoryStorage { /* private fields */ }

A simple in-memory storage implementation for testing and demonstration.

This implementation uses a HashMap wrapped in Arc<RwLock<>> for thread-safe access. It doesn’t persist data across restarts and doesn’t implement automatic expiration (expired entries are only removed during cleanup operations).

Thread Safety

This implementation is fully thread-safe and can handle concurrent operations from multiple threads.

Usage

use nonce_auth::storage::{MemoryStorage, NonceStorage};
use std::time::Duration;

let storage = MemoryStorage::new();

// Store a nonce
storage.set("test-nonce", None, Duration::from_secs(300)).await?;

// Check if it exists
let exists = storage.exists("test-nonce", None).await?;
assert!(exists);

Implementations

impl MemoryStorage

pub fn new() -> Self

Creates a new in-memory storage instance.

Trait Implementations

impl Debug for MemoryStorage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemoryStorage

fn default() -> MemoryStorage

Returns the “default value” for a type.

impl NonceStorage for MemoryStorage

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nonce: &'life1 str, context: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<NonceEntry>, NonceError>> + Send + 'async_trait>>

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

Retrieves a nonce entry if it exists.

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nonce: &'life1 str, context: Option<&'life2 str>, _ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), NonceError>> + Send + 'async_trait>>

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

Stores a new nonce with expiration time.

fn exists<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nonce: &'life1 str, context: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<bool, NonceError>> + Send + 'async_trait>>

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

Checks if a nonce exists without retrieving it.

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, cutoff_time: i64, ) -> Pin<Box<dyn Future<Output = Result<usize, NonceError>> + Send + 'async_trait>>

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

Removes all expired nonces from storage.

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<StorageStats, NonceError>> + Send + 'async_trait>>

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

Returns statistics about the storage backend.

fn init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), NonceError>> + Send + 'async_trait>>

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

Optional method for storage backend initialization.