Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

A content-addressed store of schemas, keyed by their 128-bit id.

Implementations

impl SchemaRegistry

pub fn new() -> SchemaRegistry

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

Register a schema, returning its id. Idempotent: registering the same content twice is a no-op (same id, same bytes — content-addressed).

pub fn register_canonical(&mut self, bytes: &[u8]) -> Result<u128>

Register from canonical bytes (e.g. a message’s inline schema, or a bundle entry): decodes and validates them first, so a malformed or non-canonical blob is rejected rather than stored.

pub fn get(&self, id: u128) -> Option<&Schema>

The schema with this id, if registered.

pub fn contains(&self, id: u128) -> bool

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

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

The ids of every registered schema.

pub fn resolver_for(&self, writer_id: u128, reader: &Schema) -> Result<Resolver>

Build a Resolver to read a message written with writer_id into reader — the multi-service payoff. Look up the writer schema here (it must be registered), then resolve it against the consumer’s own reader schema, so a hash-only message from a peer becomes fully readable with schema evolution intact.

writer_id is typically msg.schema_id(). Errors with Error::SchemaIdMismatch if the writer schema is not registered.

pub fn to_bundle(&self) -> Vec<u8>

Serialize every registered schema into a portable distribution bundle. Entries are ordered by id, so the bytes are deterministic (diff-friendly) and independent of insertion order.

pub fn from_bundle(bytes: &[u8]) -> Result<SchemaRegistry>

Load a registry from a distribution bundle. Every schema is decoded and validated (and thereby its id recomputed from its bytes), so a tampered bundle is rejected rather than trusted.

pub fn merge_bundle(&mut self, bytes: &[u8]) -> Result<usize>

Merge a distribution bundle into this registry, returning how many schemas were newly added (already-present ids are skipped — idempotent).

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.

impl Default for SchemaRegistry

fn default() -> SchemaRegistry

Returns the “default value” for a type.