Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Registry of all schema definitions exported by one domain schema module.

Implementations

impl SchemaRegistry

pub fn from_idl_bytes(bytes: &[u8]) -> Result<Self, SchemaIdlError>

Parses a schema registry from UTF-8 IDL JSON bytes.

Parsed names are promoted to 'static storage so the returned registry has the same lifetime shape as macro-generated registries. Repeatedly parsing unbounded IDL documents leaks those promoted strings; do not use this on a request path or hot reload loop.

pub fn from_idl_json(json: &str) -> Result<Self, SchemaIdlError>

Parses a schema registry from IDL JSON text.

See SchemaRegistry::from_idl_bytes for the lifetime and leak behavior of parsed names.

impl SchemaRegistry

pub fn to_idl_json(&self) -> String

Serializes this schema registry to stable IDL JSON.

impl SchemaRegistry

pub fn new( schema_version: Version, record_defs: &[RecordDefinition], command_defs: &[CommandDefinition], event_defs: &[EventDefinition], enum_defs: &[EnumDefinition], ) -> Self

Builds a schema registry from static definitions.

pub fn with_records( schema_version: Version, record_defs: &[RecordDefinition], ) -> Self

Builds a schema registry containing only record definitions.

pub fn schema_version(&self) -> Version

Returns the schema module version.

pub fn record_schema_fingerprint(&self) -> SchemaFingerprint

Returns the record schema fingerprint.

pub fn command_schema_fingerprint(&self) -> SchemaFingerprint

Returns the command schema fingerprint.

pub fn event_schema_fingerprint(&self) -> SchemaFingerprint

Returns the event schema fingerprint.

pub fn types_schema_fingerprint(&self) -> SchemaFingerprint

Returns the enum/type schema fingerprint.

pub fn identity(&self) -> SchemaIdentity

Returns the complete schema identity.

pub fn try_get(&self, kind: RecordKind) -> Option<&RecordDefinition>

Returns a record definition by kind.

pub fn record_defs(&self) -> impl Iterator<Item = &RecordDefinition> + '_

Iterates record definitions in stable kind order.

pub fn try_get_command(&self, kind: u8) -> Option<&CommandDefinition>

Returns a command definition by kind.

pub fn command_defs(&self) -> impl Iterator<Item = &CommandDefinition> + '_

Iterates command definitions in stable kind order.

pub fn try_get_event(&self, kind: u8) -> Option<&EventDefinition>

Returns an event definition by kind.

pub fn event_defs(&self) -> impl Iterator<Item = &EventDefinition> + '_

Iterates event definitions in stable kind order.

pub fn enum_defs(&self) -> impl Iterator<Item = &EnumDefinition> + '_

Iterates enum definitions in stable name order.

pub fn encode_pk(&self, kind: RecordKind, data: &[u8]) -> Option<PkBytes>

Encodes a primary key for a record buffer when the record supports it.

pub fn supports_pk_encoding(&self, kind: RecordKind) -> bool

Returns whether the record kind has enough metadata for primary-key encoding.

Trait Implementations

impl Clone for SchemaRegistry

fn clone(&self) -> SchemaRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SchemaRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.