Struct IdempotencyStore 

pub struct IdempotencyStore<C: CachePort> { /* private fields */ }

Cache-backed store for idempotency records.

Uses CachePort as an abstraction so it works with any backend (in-memory, Redis, etc.). Provides atomic check-and-mark via optimistic locking through the cache layer.

Implementations

impl<C: CachePort> IdempotencyStore<C>

pub const fn new(cache: Arc<C>) -> Self

Create a new store with the given cache backend and default TTL.

Example

use stygian_graph::domain::idempotency::IdempotencyStore;
use stygian_graph::adapters::cache::MemoryCache;
use std::sync::Arc;

let store = IdempotencyStore::new(Arc::new(MemoryCache::new()));

pub fn with_ttl(cache: Arc<C>, ttl: Duration) -> Self

Create a store with a custom TTL.

pub async fn get( &self, key: IdempotencyKey, ) -> Result<Option<IdempotencyRecord>>

Check whether a result is already cached for this key.

Returns None if not found or expired.

pub async fn claim(&self, key: IdempotencyKey) -> Result<bool>

Mark a key as pending (in-flight) atomically.

Returns true if the claim was acquired (key was not already present). Returns false if another worker already claimed this key.

pub async fn store( &self, key: IdempotencyKey, output: ServiceOutput, ttl: Option<Duration>, ) -> Result<()>

Store a completed result for the given key.

pub async fn mark_failed(&self, key: IdempotencyKey) -> Result<()>

Mark an operation as failed.

pub async fn invalidate(&self, key: IdempotencyKey) -> Result<()>

Invalidate a key (force re-execution on next attempt).