Struct ExecutionCatalog 

pub struct ExecutionCatalog { /* private fields */ }

File locks serialize adapters; immutable output revisions make index updates atomic.

Implementations

impl ExecutionCatalog

pub fn observe( &self, scope: &ExecutionScope, items: &[ObservationRequest], now: u64, ) -> HistoryResult<CatalogObservation>

Read retained metadata and bounded pages under one scoped catalog lock.

This performs no runtime refresh and consumes no delivery cursor. Item failures preserve their metadata and do not discard successful siblings. The outer error reports a shared catalog or request-admission failure.

impl ExecutionCatalog

pub const fn new(root: PathBuf, limits: HistoryLimits) -> Self

pub fn record( &self, scope: &ExecutionScope, capture: ExecutionCapture, ) -> HistoryResult<ExecutionRecord>

pub fn update_existing( &self, scope: &ExecutionScope, capture: ExecutionCapture, ) -> HistoryResult<Option<ExecutionRecord>>

Update a known execution without recreating an expired or foreign record.

pub fn get( &self, scope: &ExecutionScope, execution_id: &str, now: u64, ) -> HistoryResult<Option<ExecutionRecord>>

pub fn list( &self, scope: &ExecutionScope, now: u64, ) -> HistoryResult<CatalogSnapshot>

pub fn read( &self, scope: &ExecutionScope, execution_id: &str, source: OutputSource, cursor: Option<&str>, limit: usize, now: u64, ) -> HistoryResult<OutputPage>

pub fn changes( &self, scope: &ExecutionScope, cursor: &str, execution_ids: &[String], now: u64, ) -> HistoryResult<HistoryChanges>

pub fn mark_unknown( &self, scope: &ExecutionScope, execution_id: &str, reason: &str, now: u64, ) -> HistoryResult<Option<ExecutionRecord>>

Trait Implementations

impl Clone for ExecutionCatalog

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 ExecutionCatalog

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

Formats the value using the given formatter.