Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Registry for named, versioned schemas.

Implementations

impl SchemaRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&mut self, schema: Schema)

Register a schema. Overwrites any existing entry with the same name+version.

pub fn lookup(&self, name: &str, version: &str) -> Option<&Schema>

Look up a schema by name and version.

pub fn validate( &self, schema_name: &str, schema_version: &str, message: &StreamMessage, ) -> Option<ValidationResult>

Validate a message using a registered schema.

Returns None if the schema is not found.

pub fn schema_count(&self) -> usize

Number of schemas registered.

pub fn list(&self) -> Vec<(String, String)>

List all registered (name, version) pairs.

Trait Implementations

impl Default for SchemaRegistry

fn default() -> Self

Returns the “default value” for a type.