Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

Implementations

impl InMemoryBackend

pub fn new() -> Self

Trait Implementations

impl CheckpointBackend for InMemoryBackend

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 InMemoryBackend

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

Formats the value using the given formatter.

impl Default for InMemoryBackend

fn default() -> InMemoryBackend

Returns the “default value” for a type.