Struct MemoryIdempotencyStore 

pub struct MemoryIdempotencyStore { /* private fields */ }

In-memory idempotency store

Tracks extraction results by idempotency key to prevent duplicate processing. Useful for development and testing; production should use persistent storage.

Example

use stygian_plugin::storage::MemoryIdempotencyStore;
use stygian_plugin::domain::{IdempotencyKey, ExtractionResult};

let store = MemoryIdempotencyStore::new();

Implementations

impl MemoryIdempotencyStore

pub fn new() -> Self

Create a new memory-based idempotency store

Trait Implementations

impl Default for MemoryIdempotencyStore

fn default() -> Self

Returns the “default value” for a type.

impl IdempotencyKeyStore for MemoryIdempotencyStore

fn store_result<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 IdempotencyKey, result: &'life2 ExtractionResult, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Store an extraction result under an idempotency key

fn get_result<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<Option<ExtractionResult>>> + Send + 'async_trait>>

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

Retrieve a cached result by idempotency key

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

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

Delete an old result (cleanup)

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

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

Clear all results (for testing)