Struct MockIdempotencyStore 

pub struct MockIdempotencyStore { /* private fields */ }

Mock idempotency store with in-memory storage

Implementations

impl MockIdempotencyStore

pub fn new() -> Self

Create an empty idempotency store with no pre-existing events.

pub fn with_existing_events(events: Vec<(&str, &str)>) -> Self

Pre-populate with existing events for testing duplicates.

Panics

Panics if the internal mutex is poisoned (a prior panic occurred while the lock was held).

pub fn get_record( &self, provider: &str, event_id: &str, ) -> Option<IdempotencyRecord>

Retrieve the stored record for a (provider, event_id) pair, if one exists.

Panics

Panics if the internal mutex is poisoned (a prior panic occurred while the lock was held).

Trait Implementations

impl Default for MockIdempotencyStore

fn default() -> Self

Returns the “default value” for a type.

impl IdempotencyStore for MockIdempotencyStore

async fn check(&self, provider: &str, event_id: &str) -> Result<bool>

Check if event has already been processed

async fn record( &self, provider: &str, event_id: &str, event_type: &str, status: &str, ) -> Result<Uuid>

Record processed event

async fn update_status( &self, provider: &str, event_id: &str, status: &str, error: Option<&str>, ) -> Result<()>

Update event status