Struct FileEvaluationResultStore 

pub struct FileEvaluationResultStore { /* private fields */ }

A durable implementation of EvaluationResultSink.

Each mutation reads and validates one complete generation while holding a process-local mutex and an fs2 cross-process lock, then publishes a synced temporary file with an atomic replacement. Reads are safe during a replacement because they observe either the old or the new generation.

Implementations

impl FileEvaluationResultStore

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

Construct a store using the default bounded retention policy.

pub fn with_max_records( root: impl Into<PathBuf>, max_records: usize, ) -> Result<Self, EvaluationStoreError>

Construct a store with an explicit positive record-retention bound.

pub async fn open( root: impl Into<PathBuf>, ) -> Result<Self, EvaluationStoreError>

Open and validate an existing generation before admitting it to a host. A missing file is a valid empty store; malformed or newer data is returned as an error immediately.

pub async fn open_with_max_records( root: impl Into<PathBuf>, max_records: usize, ) -> Result<Self, EvaluationStoreError>

pub fn root(&self) -> &Path

pub fn max_records(&self) -> usize

pub async fn validate_store(&self) -> Result<usize, EvaluationStoreError>

Validate and count the currently persisted generation.

Unlike the compatibility EvaluationResultSink::get and list_for_target methods, this method returns storage errors so a host can fail closed on corruption instead of treating it as an empty store.

pub async fn get_checked( &self, record_digest: &str, ) -> Result<Option<EvaluationRecordV1>, EvaluationStoreError>

pub async fn list_for_target_checked( &self, target: &ExecutionTargetV1, ) -> Result<Vec<EvaluationRecordV1>, EvaluationStoreError>

Trait Implementations

impl Clone for FileEvaluationResultStore

fn clone(&self) -> FileEvaluationResultStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileEvaluationResultStore

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

Formats the value using the given formatter.

impl EvaluationResultSink for FileEvaluationResultStore

fn write<'life0, 'async_trait>( &'life0 self, record: EvaluationRecordV1, ) -> Pin<Box<dyn Future<Output = Result<EvaluationWriteOutcomeV1, EvaluationStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, record_digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<EvaluationRecordV1>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn list_for_target<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 ExecutionTargetV1, ) -> Pin<Box<dyn Future<Output = Vec<EvaluationRecordV1>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_checked<'life0, 'life1, 'async_trait>( &'life0 self, record_digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<EvaluationRecordV1>, EvaluationStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Error-reporting read variant for hosts that need to distinguish a missing record from a corrupt or unavailable backing store. Legacy implementations may use the compatibility methods above; the default keeps those implementations source-compatible.

fn list_for_target_checked<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 ExecutionTargetV1, ) -> Pin<Box<dyn Future<Output = Result<Vec<EvaluationRecordV1>, EvaluationStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,