Struct RunStore 

pub struct RunStore { /* private fields */ }

Implementations

impl RunStore

pub fn insert_claimed_run( &self, claim: &RunAdmission<'_>, now_ms: i64, ) -> Result<AdmittedRun, StoreError>

pub fn notes_for_run(&self, run_id: &str) -> Result<Vec<String>, StoreError>

impl RunStore

pub fn from_db(db: Db) -> Self

pub fn settle( &self, run_id: &str, exit_code: Option<i32>, outcome: Outcome, records: &[EvidenceRecord], cooldown: Option<&CooldownUpdate<'_>>, now_ms: i64, ) -> Result<(RecordedOutcome, bool), StoreError>

pub fn abort( &self, run_id: &str, ticket_id: &str, now_ms: i64, ) -> Result<bool, StoreError>

pub fn begin( &self, run_id: &str, branch: &str, worktree_path: &str, now_ms: i64, ) -> Result<Start, StoreError>

Hands a claimed run to its driver, recording the workspace every stage will execute in. This is the run’s start: the activity feed says so here, once, whatever kind of stage the flow opens with.

pub fn start( &self, start: &RunStart<'_>, now_ms: i64, ) -> Result<Start, StoreError>

Records the agent process an agent stage launched. The run is already under way; this only says which process the daemon is now supervising.

pub fn release_agent( &self, run_id: &str, now_ms: i64, ) -> Result<Exit, StoreError>

Returns a run to its driver after an agent stage that is not the run’s own attempt at its ticket. The exit code, commits, and vendor reading on the run belong to the first agent stage alone, so none of them move here; only ownership of the walk does.

pub fn record_exit( &self, exit: &RunExit<'_>, now_ms: i64, ) -> Result<Exit, StoreError>

Checkpoints an agent exit, granting one caller ownership of the walk.