Struct VersionedSchemaRegistry 

pub struct VersionedSchemaRegistry { /* private fields */ }

Enhanced schema registry with version history.

Provides storage and lookup for schema metadata with support for:

• Version history tracking per schema family
• Hash-based lookup for WAL replay
• Optional persistence to JSON
• Compatibility checking between versions

Implementations

impl VersionedSchemaRegistry

pub fn new() -> Self

Create a new empty registry.

pub fn with_persistence(path: impl AsRef<Path>) -> Self

Create a registry with persistence.

pub fn register(&self, info: TypeInfo)

Register a schema.

pub fn register_versioned(&self, info: TypeInfo, version: SchemaVersion)

Register a schema with explicit version.

pub fn get(&self, name: &str) -> Option<TypeInfo>

Get a schema by full name.

pub fn get_by_hash(&self, hash: u64) -> Option<TypeInfo>

Get a schema by hash.

pub fn get_versions(&self, short_name: &str) -> Vec<SchemaVersion>

Get all versions of a schema family.

pub fn get_latest(&self, short_name: &str) -> Option<TypeInfo>

Get the latest version of a schema.

pub fn get_version( &self, short_name: &str, version: SchemaVersion, ) -> Option<TypeInfo>

Get a specific version of a schema.

pub fn contains(&self, name: &str) -> bool

Check if a schema is registered.

pub fn contains_family(&self, short_name: &str) -> bool

Check if a schema family exists.

pub fn names(&self) -> Vec<String>

Get all registered schema names.

pub fn families(&self) -> Vec<String>

Get all schema families.

pub fn check_compatibility(&self, from: &str, to: &str) -> bool

Check compatibility between two schemas.

pub fn persist(&self) -> Result<()>

Persist the registry to disk.

pub fn load(path: impl AsRef<Path>) -> Result<Self>

Load the registry from disk.

pub fn clear(&self)

Clear all registered schemas.

pub fn len(&self) -> usize

Get the total number of registered schemas.

pub fn is_empty(&self) -> bool

Check if the registry is empty.

Trait Implementations

impl Default for VersionedSchemaRegistry

fn default() -> VersionedSchemaRegistry

Returns the “default value” for a type.