Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

A registry of known schema artifacts.

Replay code uses the registry to verify that every event’s schema reference points to an available artifact. Missing artifacts mean the event cannot be replayed deterministically; federation policy must fetch missing artifacts before replay proceeds (analogous to the missing-ancestor case in §5.2).

Implementations

impl SchemaRegistry

pub fn empty() -> Self

Empty registry.

pub fn insert(&mut self, artifact: SchemaArtifact) -> Result<(), String>

Insert an artifact, verifying its id matches its content.

Returns an error if the artifact’s stored id does not match its derived id. This catches tampering at registration time rather than at replay time.

pub fn get(&self, id: &str) -> Option<&SchemaArtifact>

Look up an artifact by id.

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

Whether the registry contains an artifact with the given id.

pub fn len(&self) -> usize

Number of artifacts in the registry.

pub fn is_empty(&self) -> bool

Whether the registry is empty.

pub fn ids(&self) -> impl Iterator<Item = &str>

All artifact ids in canonical (sorted) order.

pub fn missing<I: AsRef<str>>(&self, referenced: &[I]) -> Vec<String>

Detect schema artifacts referenced by referenced but missing from the registry. Used at replay-time to determine whether replay can proceed.

pub fn unknown_event_artifacts(&self, events: &[StateEvent]) -> Vec<String>

Inspect a slice of events and return any schema_artifact_id values that are not present in the registry. Events with schema_artifact_id == None are skipped (they predate the artifact-registry mechanism per docs/THEORY.md §5.1 and use the legacy string schema field).

Returned ids are deduplicated and sorted lexically.

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.

impl<'de> Deserialize<'de> for SchemaRegistry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SchemaRegistry

fn eq(&self, other: &SchemaRegistry) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SchemaRegistry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for SchemaRegistry

impl StructuralPartialEq for SchemaRegistry