Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Implementations

impl SchemaRegistry

pub fn new() -> Self

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

pub fn get_schema(&self, entity: &str) -> Option<&Schema>

pub fn validate_entity(&self, entity_name: &str, data: &Value) -> Result<()>

Errors

Returns an error if the entity has a schema and validation fails.

pub fn apply_defaults(&self, entity_name: &str, data: &mut Value) -> Result<()>

Errors

Returns an error if the entity has a schema and applying defaults fails.

pub fn persist_schema( &self, batch: &mut BatchWriter, schema: &Schema, ) -> Result<()>

Errors

Returns an error if serialization fails.

pub fn load_schemas(&mut self, storage: &Storage) -> Result<()>

Errors

Returns an error if reading or deserializing schemas fails.

pub fn validate_fields_exist( &self, entity_name: &str, fields: &[&str], context: &str, ) -> Result<()>

Errors

Returns SchemaViolation if any field doesn’t exist in the entity’s schema.

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

pub fn remove_schema(&mut self, batch: &mut BatchWriter, entity: &str)

Trait Implementations

impl Default for SchemaRegistry

fn default() -> Self

Returns the “default value” for a type.