Struct SchemaRepository 

pub struct SchemaRepository { /* private fields */ }

Thread-safe in-memory schema repository

Stores schema definitions with concurrent read/write access using DashMap. Suitable for production use with high-concurrency workloads.

Design Philosophy

• Lock-free concurrent access using sharded hash maps
• Zero-copy schema retrieval using Arc
• Type-safe schema identifiers
• Simple CRUD operations

Examples

let repo = SchemaRepository::new();
let schema_id = SchemaId::new("user-v1");
let schema = Schema::integer(Some(1), Some(100));

repo.store(schema_id.clone(), schema).unwrap();
let retrieved = repo.get(&schema_id).unwrap();

Implementations

impl SchemaRepository

pub fn new() -> Self

Create a new empty schema repository

pub fn store(&self, id: SchemaId, schema: Schema) -> ApplicationResult<()>

Store a schema definition

Arguments

• id - Unique schema identifier
• schema - Schema definition to store

Returns

Ok(()) if stored successfully

Errors

Returns error if schema with same ID already exists (use update instead)

pub fn update( &self, id: SchemaId, schema: Schema, ) -> ApplicationResult<Arc<Schema>>

Update an existing schema definition

Arguments

• id - Schema identifier
• schema - New schema definition

Returns

Ok(previous_schema) with the replaced schema if it existed

Errors

Returns error if schema does not exist (use store instead)

pub fn store_or_update( &self, id: SchemaId, schema: Schema, ) -> ApplicationResult<Option<Arc<Schema>>>

Store or update a schema (upsert operation)

Arguments

• id - Schema identifier
• schema - Schema definition

Returns

Ok(Some(previous)) if schema was updated, Ok(None) if newly created

pub fn get(&self, id: &SchemaId) -> ApplicationResult<Arc<Schema>>

Retrieve a schema by ID

Arguments

• id - Schema identifier

Returns

Ok(Arc<Schema>) if schema exists

Errors

Returns error if schema not found

pub fn exists(&self, id: &SchemaId) -> bool

Check if a schema exists

Arguments

• id - Schema identifier

Returns

true if schema exists, false otherwise

pub fn delete(&self, id: &SchemaId) -> ApplicationResult<Arc<Schema>>

Delete a schema by ID

Arguments

• id - Schema identifier

Returns

Ok(schema) with the deleted schema if it existed

Errors

Returns error if schema not found

pub fn list_ids(&self) -> Vec<SchemaId>

List all schema IDs

Returns

Vector of all schema IDs in the repository

pub fn count(&self) -> usize

Get number of schemas stored

Returns

Count of schemas in repository

pub fn clear(&self)

Clear all schemas

Removes all stored schemas from the repository.

Trait Implementations

impl Clone for SchemaRepository

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SchemaRepository

fn default() -> Self

Returns the “default value” for a type.