Struct SupabaseCheckpointStore 

pub struct SupabaseCheckpointStore { /* private fields */ }

Supabase-backed checkpoint store.

Implementations

impl SupabaseCheckpointStore

pub fn new(client: SupabaseClient) -> Self

Trait Implementations

impl CheckpointStore for SupabaseCheckpointStore

fn save( &self, checkpoint: RunCheckpoint, latest_journal_seq: u64, ) -> Result<CheckpointSaveOutcome, AgentError>

Saves checkpoint accelerator data for a run at a journal sequence. Implementations write or replace checkpoint accelerator data for the run without changing journal truth.

fn load_latest( &self, run_id: &RunId, ) -> Result<Option<RunCheckpoint>, AgentError>

Loads the latest checkpoint accelerator data for a run. Implementations read checkpoint storage for the requested run and return matching checkpoint data without altering durable journal truth.

fn load_at_or_before( &self, run_id: &RunId, cursor: &JournalCursor, ) -> Result<Option<RunCheckpoint>, AgentError>

Loads checkpoint accelerator data at or before the requested journal cursor. Implementations read checkpoint storage for the requested run and return matching checkpoint data without altering durable journal truth.

fn prune( &self, run_id: &RunId, policy: CheckpointPrunePolicy, ) -> Result<CheckpointPruneReport, AgentError>

Prunes checkpoint accelerator data according to retention policy. Implementations remove checkpoint accelerator entries according to retention policy without deleting journal truth.

impl Clone for SupabaseCheckpointStore

fn clone(&self) -> SupabaseCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.