Struct ReviewRunStore 

pub struct ReviewRunStore { /* private fields */ }

Implementations

impl ReviewRunStore

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

pub fn runs_dir(&self) -> PathBuf

pub fn path(&self, id: &str) -> PathBuf

pub fn create_queued( &self, commit_sha: &str, target: impl Into<String>, ) -> Result<ReviewRun, ReviewerError>

pub fn read(&self, id: &str) -> Result<ReviewRun, ReviewerError>

pub fn list(&self) -> Result<Vec<ReviewRun>, ReviewerError>

pub fn status_counts(&self) -> Result<ReviewRunStatusCounts, ReviewerError>

pub fn latest_result(&self) -> Result<ReviewRun, ReviewerError>

pub fn mark_running( &self, id: &str, phase: &str, ) -> Result<ReviewRun, ReviewerError>

pub fn mark_completed( &self, id: &str, ledger_entries: usize, ) -> Result<ReviewRun, ReviewerError>

pub fn mark_failed( &self, id: &str, error: impl Into<String>, ) -> Result<ReviewRun, ReviewerError>

pub fn cancel_queued(&self, id: &str) -> Result<ReviewRun, ReviewerError>

pub fn read_reconciled(&self, id: &str) -> Result<ReviewRun, ReviewerError>

Read a run and, if it is a Running zombie (recorded worker pid is dead), flip it to Failed and persist the change so review status reports the truth instead of a run stuck running forever.

pub fn list_reconciled(&self) -> Result<Vec<ReviewRun>, ReviewerError>

List all runs, reconciling any Running zombies to Failed and persisting the correction, so a dead worker never lingers as running.

pub fn cancel(&self, id: &str, force: bool) -> Result<ReviewRun, ReviewerError>

Cancel a review run, tolerating a running-but-dead worker.

• Queued runs cancel outright.
• A Running run whose worker pid is dead is reaped (marked Failed stale), so a zombie can always be cleaned up.
• A Running run with a live worker is refused unless force, which SIGKILLs the worker and then marks the run Cancelled.
• A Running legacy run with no recorded pid can only be reaped with force.
• Terminal runs (completed/failed/cancelled) are refused.

Trait Implementations

impl Clone for ReviewRunStore

fn clone(&self) -> ReviewRunStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReviewRunStore

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

Formats the value using the given formatter.