Struct FsActionStore 

pub struct FsActionStore { /* private fields */ }

The persistent two-table store: action records + CAS blobs. See the module docs for the layout and the crash-safe commit protocol.

Implementations

impl FsActionStore

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

Open (or initialize) a store rooted at root.

Creates the directory skeleton and stamps format.json on first use; refuses a root whose recorded version is not FORMAT_VERSION.

pub fn root(&self) -> &Path

The store’s root directory.

pub fn pin(&self, name: &str, key: &CacheKey) -> Result<()>

Pin an action as a GC root under a human-readable name.

pub fn pinned(&self) -> Result<Vec<CacheKey>>

All pinned action keys.

pub fn actions(&self) -> Result<Vec<ActionResult>>

Iterate every action record in the store.

pub fn evict_blob(&self, hash: &ContentHash) -> Result<()>

Remove a blob (eviction). The action records naming it stay — the value is regenerable by re-running the computation.

pub fn cas_bytes(&self) -> Result<u64>

Total bytes currently stored in the CAS.

Trait Implementations

impl ActionCache for FsActionStore

fn get_action(&self, key: &CacheKey) -> Result<Option<ActionResult>>

Look up the record for a provenance key, None on a miss.

fn put_action(&self, result: &ActionResult) -> Result<()>

Store a record under its key, replacing any existing one.

impl BlobStore for FsActionStore

fn put_bytes(&self, bytes: &[u8]) -> Result<ContentHash>

Store bytes under their content hash. Idempotent: storing the same bytes twice is a no-op.

fn get_bytes(&self, hash: &ContentHash) -> Result<Option<Vec<u8>>>

Read the blob at hash, None if absent (possibly evicted).

fn contains(&self, hash: &ContentHash) -> Result<bool>

Whether a blob exists at hash, without reading it.

impl CacheStore for FsActionStore

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

Look up the value stored under key, None on a miss.

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

Store value under key, replacing any existing entry.

fn put_with_origin( &self, key: &CacheKey, value: &Value, origin: &Origin, ) -> Result<()>

Store a value together with its provenance. Stores that persist metadata should override this; the default discards the origin.

fn put_computed( &self, key: &CacheKey, value: &Value, origin: &Origin, compute: Duration, deterministic: bool, ) -> Result<()>

Store a freshly-computed value with its full provenance record: origin, wall-clock compute cost, and the producer’s determinism declaration. Cost-aware eviction needs the compute time — a tiny value that took days must outlive a huge one that took seconds. The default discards the extra metadata.

fn exists(&self, key: &CacheKey) -> Result<bool>

Whether key has an entry, without loading the value.

fn remove(&self, key: &CacheKey) -> Result<()>

Delete the entry under key; absent keys are not an error.

fn metadata(&self, key: &CacheKey) -> Result<Option<EntryMeta>>

The entry’s [EntryMeta], without loading the value.

fn tier(&self) -> CacheTier

Which tier this store is, for reporting.

fn get_located( &self, key: &CacheKey, ) -> Result<Option<(Value, CacheTier)>, SomaError>

Like [CacheStore::get], but also reports which tier served the value.