Struct ModelRegistry 

pub struct ModelRegistry { /* private fields */ }

Thread-safe registry with optional durable backend.

Cloning is cheap — the Arcs shared. Mutations flush to the attached MlPersistence (when present) so state survives restart. Without a backend the registry is pure in-memory, which is what the unit tests use.

Implementations

impl ModelRegistry

pub fn new() -> ModelRegistry

pub fn with_backend(backend: Arc<dyn MlPersistence>) -> ModelRegistry

Build a registry that persists mutations to backend and rehydrates from any existing entries. Callers typically construct this once at startup via the runtime helper.

pub fn load_from_backend(&self) -> Result<(), ModelRegistryError>

Read every persisted model + version back into memory. Called implicitly by Self::with_backend; also exposed so tests can assert round-trip.

pub fn register_version( &self, model: impl Into<String>, version: ModelVersion, make_active: bool, ) -> Result<u32, ModelRegistryError>

Register a new version of model. Returns the new version number, which is always max(existing) + 1.

The registered version becomes the active one automatically unless make_active = false — callers who want to validate before publishing pass false and later call Self::set_active_version.

pub fn set_active_version( &self, model: &str, version: u32, ) -> Result<(), ModelRegistryError>

Point the active_version at version. Errors if the version does not exist or is archived.

pub fn archive_version( &self, model: &str, version: u32, ) -> Result<(), ModelRegistryError>

Flag a version as archived. Archived versions remain readable (so offline audits work) but cannot be made active. If the archived version was the active one, active_version is cleared — operator must explicitly pick a new active version.

pub fn get_version( &self, model: &str, version: u32, ) -> Result<ModelVersion, ModelRegistryError>

Fetch a specific version. Clones because callers typically need an owned blob.

pub fn get_active( &self, model: &str, ) -> Result<Option<ModelVersion>, ModelRegistryError>

Fetch the currently-active version of model, if one is set.

pub fn list_versions( &self, model: &str, ) -> Result<Vec<ModelVersion>, ModelRegistryError>

List every version of model, oldest first.

pub fn summaries(&self) -> Result<Vec<ModelSummary>, ModelRegistryError>

One-line summary per model.

Trait Implementations

impl Clone for ModelRegistry

fn clone(&self) -> ModelRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ModelRegistry

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

Formats the value using the given formatter.

impl Default for ModelRegistry

fn default() -> ModelRegistry

Returns the “default value” for a type.