Struct MemorySchemaStore 

pub struct MemorySchemaStore { /* private fields */ }

In-memory SchemaStore backed by DashMap.

Each (upstream_id, method) key owns a FIFO ring buffer of at most capacity versions. On insert overflow, the oldest version is dropped and its id removed from the lookup index.

Implementations

impl MemorySchemaStore

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

Trait Implementations

impl Clone for MemorySchemaStore

fn clone(&self) -> MemorySchemaStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MemorySchemaStore

fn default() -> Self

Returns the “default value” for a type.

impl SchemaStore for MemorySchemaStore

async fn put_version(&self, version: SchemaVersion) -> SchemaVersion

Insert a new version. Implementations handle retention / eviction. Returns the stored version (the caller may not have populated version correctly — implementations may assign it).

async fn get_version(&self, id: &SchemaVersionId) -> Option<SchemaVersion>

Fetch a specific version by id. None if never stored or evicted.

async fn latest_version_for_method( &self, upstream_id: &str, method: &str, ) -> Option<SchemaVersion>

Latest version for a given (upstream_id, method).

async fn list_versions( &self, upstream_id: &str, method: &str, ) -> Vec<SchemaVersion>

All versions for a given (upstream_id, method), newest first. Bounded by the store’s retention policy.

async fn prune(&self, upstream_id: &str, method: &str, keep: usize)

Drop versions older than keep for (upstream_id, method). Idempotent. Default impl is a no-op for stores without explicit pruning.