Skip to main content

ModelStore

Struct ModelStore 

Source
pub struct ModelStore { /* private fields */ }
Expand description

Handle to a model store rooted at one $MODELS_HOME.

Cheap to construct (just resolves paths). All disk creation is lazy: directories are made on first write.

Implementations§

Source§

impl ModelStore

Source

pub fn open(root: impl Into<PathBuf>) -> Self

Open a store rooted at root. Resolves ~ to the home dir.

Source

pub fn at_platform_default() -> Self

Open the store at the platform default location.

Source

pub fn root(&self) -> &Path

Root path of this store ($MODELS_HOME).

Source

pub fn blob_path(&self, sha256_hex: &str) -> PathBuf

Path to the blobs/sha256/<aa>/<full-hash>/data blob for a SHA-256 hex string. Does NOT check existence.

Source

pub fn partial_path(&self, sha256_hex: &str) -> PathBuf

Path to the in-progress data.tmp for a download. Lives in a .partial-<hash> sibling so abandoned downloads are trivially distinguishable from finalised blobs.

Source

pub fn manifest_path(&self, name: &str) -> PathBuf

Path to a manifest by name.

Source

pub fn lock_path(&self, name: &str) -> PathBuf

Path to the advisory lock file for name. Producers hold an exclusive lock on this file across blob-write + manifest-write to keep two daemons from racing on the same name.

Source

pub fn quarantine_dir(&self) -> PathBuf

Directory where bad blobs are quarantined. Per ADR 0011 we keep these for forensic inspection rather than deleting them.

Source

pub fn read_manifest(&self, name: &str) -> Result<Option<Manifest>>

Read a manifest by name. Returns Ok(None) if absent so callers can branch on present/missing without parsing IO kinds.

Source

pub fn write_manifest(&self, manifest: &Manifest) -> Result<PathBuf>

Write a manifest atomically: write to <path>.tmp, then rename. The blob it references must already exist on disk — callers are expected to write the blob first.

Source

pub fn quarantine(&self, src: &Path, reason: &str) -> Result<PathBuf>

Move a bad-bytes file into the quarantine dir under a timestamped name. Returns the new path.

Source

pub fn ensure_layout(&self) -> Result<()>

Ensure the on-disk skeleton (blobs/, manifests/, locks/) exists. Idempotent.

Trait Implementations§

Source§

impl Clone for ModelStore

Source§

fn clone(&self) -> ModelStore

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for ModelStore

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more