Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Available on crate features cqrs and cqrs-allsource only.

Central registry for managing event schemas

Implementations

impl SchemaRegistry

pub fn new(config: SchemaRegistryConfig) -> SchemaRegistry

pub fn register_schema( &self, subject: String, schema: Value, description: Option<String>, tags: Option<Vec<String>>, ) -> Result<RegisterSchemaResponse, AllSourceError>

Register a new schema or return existing if identical

pub fn get_schema( &self, subject: &str, version: Option<u32>, ) -> Result<Schema, AllSourceError>

Get a schema by subject and version (or latest if no version specified)

pub fn list_versions(&self, subject: &str) -> Result<Vec<u32>, AllSourceError>

List all versions of a schema subject

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

List all schema subjects

pub fn validate( &self, subject: &str, version: Option<u32>, payload: &Value, ) -> Result<ValidateEventResponse, AllSourceError>

Validate a payload against a schema

pub fn set_compatibility_mode(&self, subject: String, mode: CompatibilityMode)

Set compatibility mode for a subject

pub fn get_compatibility_mode(&self, subject: &str) -> CompatibilityMode

Get compatibility mode for a subject (or default)

pub fn delete_schema( &self, subject: &str, version: u32, ) -> Result<bool, AllSourceError>

Delete a specific schema version

pub fn stats(&self) -> SchemaRegistryStats

Get registry statistics

pub fn config(&self) -> &SchemaRegistryConfig

Get registry configuration