Struct SqliteCheckpoint 

pub struct SqliteCheckpoint { /* private fields */ }

Stores latest checkpoints, transcripts, and middleware state in SQLite.

Implementations

impl SqliteCheckpoint

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

Opens or creates a durable checkpoint database.

Errors

Returns an error if configuration is invalid or a required resource cannot be initialized.

Trait Implementations

impl CheckpointStore for SqliteCheckpoint

fn load<'a>( &'a self, session_id: &'a str, ) -> BoxFuture<'a, Result<Option<Checkpoint>>>

Loads the latest checkpoint for a session.

fn delete_sessions<'a>( &'a self, session_ids: &'a [String], ) -> BoxFuture<'a, Result<bool>>

Atomically deletes the selected sessions, their descendants, and session-scoped state.

fn save<'a>( &'a self, checkpoint: &'a Checkpoint, transcript_delta: &'a [Value], execution: Option<&'a ExecutionRecord>, ) -> BoxFuture<'a, Result<()>>

Atomically replaces the checkpoint, appends transcript items, and records a finished turn.

fn save_with_events<'a>( &'a self, checkpoint: Checkpoint, transcript_delta: Vec<Value>, execution: Option<ExecutionRecord>, events: Vec<TimestampedEvent>, ) -> BoxFuture<'a, Result<Vec<JournalEvent>>>

Atomically saves one owned checkpoint and appends its normalized event batch.

fn append_event<'a>( &'a self, session_id: &'a str, recorded_at_ms: i64, event: &'a Event, ) -> BoxFuture<'a, Result<JournalEvent>>

Assigns a session-local sequence and appends one normalized event atomically.

fn event_page<'a>( &'a self, session_id: &'a str, request: EventPageRequest, ) -> BoxFuture<'a, Result<EventPage>>

Loads one newest-first page of normalized session events.

fn session_summary<'a>( &'a self, session_id: &'a str, ) -> BoxFuture<'a, Result<Option<SessionSummary>>>

Loads catalog metadata for one session without reading its checkpoint context.

fn list_sessions_page( &self, request: SessionPageRequest, ) -> BoxFuture<'_, Result<SessionPage>>

Lists one page of the most recently updated sessions, newest first.

fn transcript_page<'a>( &'a self, session_id: &'a str, request: TranscriptPageRequest, ) -> BoxFuture<'a, Result<TranscriptPage>>

Loads one newest-first page of append-only transcript deltas.

fn execution_page<'a>( &'a self, session_id: &'a str, request: ExecutionPageRequest, ) -> BoxFuture<'a, Result<ExecutionPage>>

Loads one newest-first page of terminal user-turn records.

fn recent_executions( &self, limit: usize, ) -> BoxFuture<'_, Result<Vec<ExecutionRecord>>>

Loads the most recently started terminal user turns across all sessions.

fn fork<'a>( &'a self, parent_session_id: &'a str, parent_sequence: u64, checkpoint: &'a Checkpoint, ) -> BoxFuture<'a, Result<SessionSummary>>

Creates a child session at an exact durable parent sequence.

fn load_state<'a>( &'a self, scope: &'a str, key: &'a str, ) -> BoxFuture<'a, Result<Option<Value>>>

Loads the latest opaque state owned by one middleware namespace.

fn save_state<'a>( &'a self, scope: &'a str, key: &'a str, value: &'a Value, ) -> BoxFuture<'a, Result<()>>

Durably replaces opaque middleware state.