Struct InMemoryIdempotencyStore 

pub struct InMemoryIdempotencyStore<T> { /* private fields */ }

A process-local store of completed results, one Mutex wide.

Example

use std::num::NonZeroUsize;

use protocol_droid::adapters::secondary::idempotency::InMemoryIdempotencyStore;
use protocol_droid::application::idempotency::IdempotencyStore;
use protocol_droid::domain::idempotency::{Claim, IdempotencyKey};

let store = InMemoryIdempotencyStore::with_capacity(NonZeroUsize::MIN);
let key = IdempotencyKey::new("req-1");

let first = store.claim(&key)?;
assert!(first.is_execution_mine());
let token = first.token().ok_or("claimed without a token")?;
store.complete(token, "charged once")?;

// The client retries because the connection dropped. It gets the recorded
// result and no second charge.
let replay = store.claim(&key)?;
// `matches!` on a `&replay` binds `result` as `&&str`, so the recorded
// value is two derefs in.
assert!(matches!(&replay, Claim::Completed(result) if **result == *"charged once"));

Implementations

impl<T> InMemoryIdempotencyStore<T>

pub fn with_capacity(capacity: NonZeroUsize) -> Self

A store holding at most capacity keys.

Bounded because the keys are peer-chosen; see CompletedResults::with_capacity.

pub fn capacity(&self) -> Result<usize, IdempotencyError>

The ceiling, in keys.

Takes the lock, so a poisoned store reports the error rather than a made-up number.

Errors

IdempotencyError::Unavailable when the lock is poisoned.

pub fn len(&self) -> Result<usize, IdempotencyError>

How many keys are held, including claims that are still in flight.

Errors

IdempotencyError::Unavailable when the lock is poisoned.

pub fn is_empty(&self) -> Result<bool, IdempotencyError>

Whether nothing is held.

Errors

IdempotencyError::Unavailable when the lock is poisoned.

Trait Implementations

impl<T: Debug> Debug for InMemoryIdempotencyStore<T>

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

Formats the value using the given formatter.

impl<T> Default for InMemoryIdempotencyStore<T>

fn default() -> Self

A store of default_capacity keys.

impl<T: Clone + Send + Sync> IdempotencyStore for InMemoryIdempotencyStore<T>

type Result = T

What a completed side effect produced. The adapter’s own result type — an IrResult for a tool call, a transport payload for a bridge forward.

fn claim(&self, key: &IdempotencyKey) -> Result<Claim<T>, IdempotencyError>

Takes ownership of key, or reports that it is already spoken for.

fn complete( &self, token: &ClaimToken, result: T, ) -> Result<(), IdempotencyError>

Records the result of a claim the caller owns.

fn abandon(&self, token: &ClaimToken) -> Result<(), IdempotencyError>

Releases a claim whose execution did not produce a result.