Struct FileWorkflowRunStore 

pub struct FileWorkflowRunStore { /* private fields */ }

Directory of *.json records + optional shared journal root.

Layout:

{root}/
  index.jsonl          # optional append-only index (rewritten on put for simplicity: one file per run)
  runs/{run_id}.json
  journals/{run_id}.jsonl   # conventional journal path helper

Implementations

impl FileWorkflowRunStore

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

Root directory (created on demand).

pub fn root(&self) -> &Path

Root accessor.

pub fn journal_path_for(&self, run_id: &str) -> PathBuf

Conventional journal path for a run id.

Trait Implementations

impl Clone for FileWorkflowRunStore

fn clone(&self) -> FileWorkflowRunStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileWorkflowRunStore

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

Formats the value using the given formatter.

impl WorkflowRunStore for FileWorkflowRunStore

fn put(&self, record: WorkflowRunRecord) -> Result<(), StoreError>

Insert or replace a record.

fn get(&self, run_id: &str) -> Result<Option<WorkflowRunRecord>, StoreError>

Fetch by run id.

fn list(&self) -> Result<Vec<WorkflowRunRecord>, StoreError>

List all runs (newest-updated first when possible).

fn delete(&self, run_id: &str) -> Result<bool, StoreError>

Remove a run metadata entry (does not delete the journal file).