Struct Catalog 

pub struct Catalog {
    pub models: Vec<CatalogModel>,
    pub dismissed_seeds: Vec<String>,
}

A collection of locally-available models.

Fields

models: Vec<CatalogModel>

dismissed_seeds: Vec<String>

Seed ids the operator deleted; startup seeding never re-adds them.

Implementations

impl Catalog

pub fn seed() -> Self

The built-in catalog: every model the worker ships seeded with.

pub fn ensure_seeds(&mut self) -> bool

Add every seed this catalogue lacks (an install that predates it), never replacing the operator’s entry and never re-adding a seed they deleted. true when anything was added.

pub fn from_json(json: &str) -> Result<Self>

Parse a catalog from a JSON string.

pub fn to_json(&self) -> Result<String>

Serialise to pretty JSON.

pub fn load_or_seed(path: &Path) -> Result<Self>

Load the catalog from path.

• Missing file → seeded with the built-in defaults and written.
• Corrupt JSON → the file is quarantined (renamed to models.json.corrupt-<unix-ts>) and a fresh seed written in its place. The old behaviour — erroring so the caller fell back to an in-memory seed while keeping the save path — meant the next persist silently overwrote the operator’s hand-edited catalog; quarantining preserves their bytes for recovery.
• Any other IO error propagates (nothing is renamed or written).

pub fn load_for_serving(path: Option<PathBuf>) -> (Self, Option<PathBuf>)

Load for serving: the catalog plus the path future saves may write to. A quarantine/seed recovery keeps the path (the file is now healthy); an unreadable file (permissions, IO) drops it so the worker can never overwrite a file it couldn’t read.

pub fn save(&self, path: &Path) -> Result<()>

Write the catalog to path (creating parent dirs) — atomically, via the same temp-file + rename dance as config.toml, so a crash mid-write can’t truncate the operator’s model catalog.

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

Look up a model by id.

pub fn list(&self) -> &[CatalogModel]

All catalog entries.

pub fn upsert(&mut self, model: CatalogModel)

Insert a model, replacing any existing entry with the same id.

pub fn sync_studio_model(&mut self, incoming: CatalogModel) -> bool

Mirror a model seen on a studio job offer into the catalog so the local API can serve it too. Returns whether the catalog changed (a no-op returns false, so the caller can skip the disk write). A local-origin entry of the same id is never clobbered — the operator’s own edits win; an unchanged studio-origin entry is left alone so a re-offer every job doesn’t churn the file.

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

Remove a model by id. Returns whether it existed.

pub fn default_image_model(&self) -> Option<&CatalogModel>

The first enabled image model — used when a request names no model.

pub fn default_model_for(&self, kind: TaskKind) -> Option<&CatalogModel>

The first enabled model of kind — used when a request for that kind names no explicit model. Generalises default_image_model so the local API can serve every modality the worker’s engines support.

Trait Implementations

impl Clone for Catalog

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Catalog

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

Formats the value using the given formatter.

impl Default for Catalog

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Catalog

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Catalog

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Catalog

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Catalog