Struct SchemaRegistry 

pub struct SchemaRegistry<S: StorageEngine> { /* private fields */ }

Per-array SchemaDoc registry.

Thread-safe via an internal Mutex. Multiple subsystems hold an Arc<SchemaRegistry<S>> and call into it independently.

Implementations

impl<S: StorageEngine> SchemaRegistry<S>

pub fn new(storage: Arc<S>, replica: Arc<ReplicaState>) -> Self

Create an empty registry (no cold-start scan).

Use [load] to reconstruct persisted schemas on startup.

pub async fn load( storage: Arc<S>, replica: Arc<ReplicaState>, ) -> Result<Self, LiteError>

Load all persisted SchemaDoc snapshots from storage.

Reads every Namespace::Meta key under b"array.schema_doc:".

pub async fn put_schema( &self, name: &str, schema: &ArraySchema, ) -> Result<Hlc, LiteError>

Register or replace the schema for name, minting a new Hlc.

Persists a Loro snapshot under the schema key so the registry survives restarts. Returns the freshly minted schema_hlc.

pub fn schema_hlc(&self, name: &str) -> Option<Hlc>

Return the current schema_hlc for name, or None if unknown.

pub async fn import_snapshot( &self, name: &str, snapshot_bytes: &[u8], remote_hlc: Hlc, ) -> Result<(), LiteError>

Apply a remote Loro snapshot for name.

Creates the entry if absent. Persists the updated snapshot. The inbound schema-sync handler calls this for each schema message.

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

Return all array names currently registered in this registry.

pub fn export_snapshot(&self, name: &str) -> Result<Option<Vec<u8>>, LiteError>

Export the current Loro snapshot bytes for name.

Returns None if name is not registered.

pub fn export_versioned( &self, name: &str, ) -> Result<Option<(Hlc, Vec<u8>)>, LiteError>

Export name’s current schema_hlc and Loro snapshot together.

Both come from one lock acquisition, so the HLC always describes the snapshot it travels with. Returns None if name is not registered.