Skip to main content

Cache

Struct Cache 

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

The cache: a directory tree of one JSON file per entry, keyed by blake3 digest of the six prompt and backend inputs.

Built once per process and shared across the analyzer; every method takes &self so Cache can live behind an Arc if a future caller needs it.

Implementations§

Source§

impl Cache

Source

pub fn new(root: PathBuf, ttl_days: u64, max_bytes: u64) -> Self

Build a cache rooted at root without touching the filesystem.

put creates its shard on demand. Keeping construction lazy lets site policy decide whether a semantic layer exists before that layer acquires any on-disk state.

Source

pub fn default_root() -> PathBuf

The conventional location: directories::ProjectDirs::cache_dir(), falling back to .drep-cache in the cwd when the platform has no cache directory. Returned as a relative path on the fallback branch so the caller can resolve it against whatever cwd they choose.

Source

pub fn key( &self, system_prompt: &str, content: &str, backend: &str, model: &str, request_shape: &str, temperature: Option<f32>, ) -> CacheKey

Compute the key for (system_prompt, content, backend, model, request_shape, temperature).

Deliberately does NOT consult self: the key is content-only, so two Cache instances at different roots produce the same key for the same inputs. That is what criterion 7 asserts and what makes the cache portable across CI runs.

request_shape is in the key because one endpoint can serve the same model over both wire formats - api.minimax.io publishes /v1 and /anthropic/v1 for MiniMax-M3 - and the two are different requests with different reasoning handling. Keying without it files one protocol’s answer where the other looks for its own, which is the same defect that put endpoint in the key.

Source

pub fn get(&self, key: &CacheKey) -> Option<Value>

Read the entry at key, or None if absent, expired, unreadable, or unparseable. Reads never fail.

An expired entry is removed opportunistically; a corrupt or unreadable entry is left in place so the next read has another chance (transient I/O is more likely than persistent corruption, and a half-deleted cache is worse than a slightly redundant one).

Source

pub fn put(&self, key: &CacheKey, value: &Value) -> Result<(), CacheError>

Write value to disk under key.

Creates the shard directory on demand so the very first put into a fresh cache does not need a separate bootstrap step.

Source

pub fn evict_if_needed(&self) -> Result<u64, CacheError>

Walk the tree, evicting the oldest entries (by mtime) until the total size is at or under max_bytes. Returns the number of bytes freed; 0 when no eviction was needed.

Trait Implementations§

Source§

impl Clone for Cache

Source§

fn clone(&self) -> Cache

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 Cache

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl Freeze for Cache

§

impl RefUnwindSafe for Cache

§

impl Send for Cache

§

impl Sync for Cache

§

impl Unpin for Cache

§

impl UnsafeUnpin for Cache

§

impl UnwindSafe for Cache

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> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

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

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
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 = !

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