Struct SqliteCheckpointBackend 

pub struct SqliteCheckpointBackend { /* private fields */ }

SQLite-backed checkpoint backend.

Wraps an EventWriter for structured event-to-SQL translation and adds checkpoint table management on top. Maintains an in-memory checkpoint cache for O(1) hot-path reads.

Implementations

impl SqliteCheckpointBackend

pub fn new(pool: DbPool, run_id: RunId) -> Self

Create a new backend for the given run.

Trait Implementations

impl CheckpointBackend for SqliteCheckpointBackend

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

Initialize a new run.

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

Initialize a new run with declarative workflow metadata.

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

Open an existing run for resume. Returns None if not found.

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

Append an event to the log and update checkpoint state.

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

Insert or update an agent result.

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

Insert or update an agent session.

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

Get current checkpoint (from in-memory cache).

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

Get all findings.

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

Get event log as a vector.

fn can_resume(&self) -> bool

Check if a run can be resumed.

fn reset_status_to_running(&self) -> Result<()>

Reset checkpoint status to Running.

fn cancel(&self) -> Result<()>

Mark run as cancelled.

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

Save checkpoint (full overwrite).

impl Debug for SqliteCheckpointBackend

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

Formats the value using the given formatter.