Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Central registry for managing event schemas

Implementations

impl SchemaRegistry

pub fn new(config: SchemaRegistryConfig) -> Self

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

Register a new schema or return existing if identical

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

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

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

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: &JsonValue, ) -> Result<ValidateEventResponse>

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>

Delete a specific schema version

pub fn stats(&self) -> SchemaRegistryStats

Get registry statistics

pub fn config(&self) -> &SchemaRegistryConfig

Get registry configuration