Struct LocalSessionStore 

pub struct LocalSessionStore { /* private fields */ }

Session store bound to a resolved CLI database path.

Implementations

impl LocalSessionStore

pub fn new(config: CliConfig) -> SessionStoreResult<Self>

Open a CLI session-store adapter before it is used by async runtime code.

Trait Implementations

impl Clone for LocalSessionStore

fn clone(&self) -> LocalSessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalSessionStore

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

Formats the value using the given formatter.

impl SessionStore for LocalSessionStore

fn commit_run_evidence<'life0, 'async_trait>( &'life0 self, commit: RunEvidenceCommit, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<RunRecord>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Atomically persist a complete run evidence bundle.

fn commit_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, checkpoint: AgentCheckpoint, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically bootstrap missing session/run records and persist one runtime checkpoint.

fn claim_hitl_resume<'life0, 'async_trait>( &'life0 self, claim: HitlResumeClaim, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Acquire exclusive ownership of a waiting run before any continuation side effect.

fn mark_hitl_resume_started<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, claim_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Mark a claim started immediately before the first continuation hook or tool executes.

fn release_hitl_resume_claim<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, claim_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Release a preflight claim. Stores must reject release after execution has started.

fn pending_stream_publications<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<PendingStreamPublication>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List transactionally enqueued stream publications still awaiting at least one sink.

fn acknowledge_stream_publication<'life0, 'life1, 'async_trait>( &'life0 self, publication_id: &'life1 str, target: StreamPublicationTarget, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acknowledge one sink only after its complete idempotent delivery succeeds.

fn save_session<'life0, 'async_trait>( &'life0 self, session: SessionRecord, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Save a session record.

fn load_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<SessionRecord>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load a session record.

fn list_sessions<'life0, 'async_trait>( &'life0 self, filter: SessionFilter, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<SessionRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List sessions by optional filter.

fn update_session_status<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, status: SessionStatus, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update session status.

fn save_context_state<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, state: ResumableState, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a context state snapshot for a session.

fn save_environment_state<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, environment_state: EnvironmentStateRef, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save an environment state reference for a session.

fn append_run<'life0, 'async_trait>( &'life0 self, run: RunRecord, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append or replace a run record.

fn load_run<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<RunRecord>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load a run record.

fn list_runs<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<RunRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List runs for a session.

fn update_run_status<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, status: RunStatus, output_preview: Option<String>, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update run status and optional output preview.

fn append_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, checkpoint: AgentCheckpoint, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append a full runtime checkpoint.

fn load_checkpoints<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<AgentCheckpoint>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load checkpoints for a run in insertion order.

fn append_stream_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, records: Vec<AgentStreamRecord>, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append runtime stream records used as resume evidence.

fn replay_stream_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<AgentStreamRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Replay runtime stream records for a run.

fn replay_stream_records_after<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, after_sequence: Option<usize>, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<AgentStreamRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Replay runtime stream records after a sequence cursor.

fn save_stream_cursor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, cursor: StreamCursorRef, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store a stream cursor reference for a run and session.

fn append_approval<'life0, 'async_trait>( &'life0 self, approval: ApprovalRecord, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append an approval record.

fn load_approvals<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<ApprovalRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load approval records for a run.

fn append_deferred_tool<'life0, 'async_trait>( &'life0 self, record: DeferredToolRecord, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append a deferred tool record.

fn load_deferred_tools<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<Vec<DeferredToolRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load deferred tool records for a run.

fn compact_run_trace<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<CompactRunTrace>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Return compact run trace projection.

fn compact_session_trace<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionStoreResult<CompactSessionTrace>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return compact session trace projection.

fn latest_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentCheckpoint>, SessionStoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Load the latest checkpoint for a run.

fn resume_snapshot<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _session_id: &'life1 SessionId, _run_id: &'life2 RunId, ) -> Pin<Box<dyn Future<Output = Result<SessionResumeSnapshot, SessionStoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Load a resume snapshot from session, checkpoint, and stream evidence.