Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

Minimal in-memory backend. Not durable; intended for tests and prototyping. Concurrency-safe (a single Mutex over the table).

Implementations

impl InMemoryStore

pub fn new() -> Self

Construct an empty store.

Trait Implementations

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl RegistryStore for InMemoryStore

fn put(&self, body: Body) -> Result<(), AcdpError>

Persist a freshly-assigned context. body.ctx_id and body.lineage_id are already populated by the server.

fn get(&self, ctx_id: &CtxId) -> Result<Option<FullContext>, AcdpError>

Retrieve a stored context by ctx_id.

fn lineage(&self, lineage_id: &LineageId) -> Result<Vec<FullContext>, AcdpError>

All contexts in a lineage, oldest first.

fn current( &self, lineage_id: &LineageId, ) -> Result<Option<FullContext>, AcdpError>

Returns the newest non-Status::Superseded version of a lineage — either Status::Active or Status::Expired (an expired-but-unreplaced body is still the latest version, and callers need to see it to know it has lapsed).

fn mark_superseded(&self, ctx_id: &CtxId) -> Result<(), AcdpError>

Mark ctx_id’s registry state as superseded. Idempotent.

fn first_version_ctx_id( &self, lineage_id: &LineageId, ) -> Result<Option<CtxId>, AcdpError>

First-version ctx_id for a lineage, used to derive the lineage_id of a supersession publish per RFC-ACDP-0001 §5.6.

fn idempotency_lookup( &self, agent_id: &AgentDid, key: &str, ) -> Result<Option<IdempotencyRecord>, AcdpError>

Look up a prior publish record for (agent_id, key).

fn idempotency_record( &self, agent_id: &AgentDid, key: &str, hash: &ContentHash, response: &PublishResponse, expires_at: DateTime<Utc>, ) -> Result<(), AcdpError>

Record a successful publish under (agent_id, key) with TTL expires_at. Calling on a store that does not support idempotency is a no-op.

fn idempotency_evict_expired(&self, now: DateTime<Utc>) -> Result<(), AcdpError>

Evict records whose expires_at is past now. Implementations may call this on a janitor schedule or lazily at lookup time.

fn commit_publish( &self, commit: PublishCommit<'_>, ) -> Result<PublishCommitOutcome, AcdpError>

Atomically commit a publish: idempotency lookup, supersession validation, body insertion, predecessor supersession marking, and idempotency record write — all under a single critical section so two concurrent publishes targeting the same supersedes (or sharing an idempotency_key) cannot both succeed.

fn search( &self, params: &SearchParams, requester: Option<&AgentDid>, anonymous_public_reads: bool, ) -> Result<SearchResponse, AcdpError>

Keyword/filter search. Implementations MUST apply the RFC-ACDP-0008 §4.5 search-disclosure rules using requester: