Struct MemorySchemaRegistry 

pub struct MemorySchemaRegistry { /* private fields */ }

In-memory schema registry for development and testing

Stores schemas in a HashMap protected by RwLock. Schemas are lost on process restart.

Implementations

impl MemorySchemaRegistry

pub fn new() -> Self

Create a new empty registry

Trait Implementations

impl Default for MemorySchemaRegistry

fn default() -> Self

Returns the “default value” for a type.

impl SchemaRegistry for MemorySchemaRegistry

fn register(&self, schema: EventSchema) -> Result<()>

Register a schema for an event type at a specific version

fn get(&self, event_type: &str, version: u32) -> Result<Option<EventSchema>>

Get the schema for an event type at a specific version

fn latest_version(&self, event_type: &str) -> Result<Option<u32>>

Get the latest schema version for an event type

fn list_types(&self) -> Result<Vec<String>>

List all registered event types

fn validate(&self, event: &Event) -> Result<()>

Validate an event’s payload against its registered schema

fn check_compatibility( &self, event_type: &str, new_version: u32, mode: Compatibility, ) -> Result<()>

Check if a new schema version is compatible with the previous version