Struct FileExecutionStore 

pub struct FileExecutionStore { /* private fields */ }

File-system-backed ExecutionStore that stores one JSON file per execution.

Storage layout:

base_dir/
└── executions/
    ├── {id}.json
    └── ...

Implementations

impl FileExecutionStore

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

Create a new FileExecutionStore rooted at dir.

Trait Implementations

impl ExecutionStore for FileExecutionStore

fn save<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 ExecutionRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Persist an execution record.

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

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

Retrieve an execution record by ID, returning None if not found.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 ExecutionFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<ExecutionRecord>>> + Send + 'async_trait>>

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

List execution records matching the given filter.

fn stats<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 ExecutionFilter, ) -> Pin<Box<dyn Future<Output = Result<ExecutionStats>> + Send + 'async_trait>>

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

Compute aggregated statistics for executions matching the filter.

fn prune<'life0, 'async_trait>( &'life0 self, older_than_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Delete execution records whose finished_at is older than the given unix timestamp in milliseconds. Returns the number of records deleted.