Struct RunStore 

pub struct RunStore { /* private fields */ }

Persistence store for a single run.

Implementations

impl RunStore

pub fn new(run_dir: &Path) -> Result<Arc<Self>, Error>

Create or open a run store at the given path.

pub fn upsert_agent_result(&self, cache: &AgentResultCache) -> Result<(), Error>

Insert or update an agent result in the checkpoint directly. Used by JournalStore to persist cache_key_hash before appending the event.

pub fn upsert_agent_session( &self, session: &AgentSessionCheckpoint, ) -> Result<(), Error>

Insert or update an agent session in the checkpoint.

pub fn init_run(&self, run_id: RunId, task: &str) -> Result<(), Error>

Initialize a new run.

pub fn init_run_with_meta( &self, run_id: RunId, task: &str, workflow_meta: Value, ) -> Result<(), Error>

Initialize a new run with declarative workflow metadata.

pub fn open_run(&self, _run_id: RunId) -> Result<Option<RunCheckpoint>, Error>

Open an existing run for resume.

pub fn append_event(&self, event: &AgentEvent) -> Result<(), Error>

Append an event to the log.

pub fn save_checkpoint(&self, checkpoint: &RunCheckpoint) -> Result<(), Error>

Save checkpoint to disk (public API, acquires lock).

pub fn get_checkpoint(&self) -> Option<RunCheckpoint>

Get current checkpoint.

pub fn get_findings(&self) -> Vec<Finding>

Get all findings collected so far.

pub fn get_event_log(&self) -> Result<Vec<AgentEvent>, Error>

Get event log as a vector.

pub fn can_resume(&self) -> bool

Check if a run can be resumed.

pub fn reset_status_to_running(&self) -> Result<(), Error>

Reset checkpoint status to Running. Used when resuming a failed/cancelled run — the terminal status is replaced so that status queries reflect the active execution and a crash leaves a resumable checkpoint.

pub fn cancel(&self) -> Result<(), Error>

Mark run as cancelled.

Trait Implementations

impl Debug for RunStore

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

Formats the value using the given formatter.