Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Cloneable SQLite-backed effect, checkpoint, and journal store.

Clones share one connection and serialize operations at the connection boundary. SQLite transactions still provide persistence and CAS guarantees across separately opened store instances and processes.

Implementations

impl SqliteStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, SqliteStoreError>

Opens or creates a file-backed store and initializes its schema.

Errors

Returns SqliteStoreError when the database cannot be opened or initialized.

pub fn open_in_memory() -> Result<Self, SqliteStoreError>

Creates a process-local SQLite database, primarily for tests.

Errors

Returns SqliteStoreError when SQLite initialization fails.

pub fn events(&self, run_id: RunId) -> Result<Vec<RunEvent>, SqliteStoreError>

Loads all journal events for one Run in sequence order.

Errors

Returns SqliteStoreError when querying or decoding fails.

Trait Implementations

impl ArtifactStore for SqliteStore

fn put( &self, write: ArtifactWrite, ) -> ArtifactFuture<'_, Result<ArtifactRef, ArtifactError>>

Idempotently writes content and returns its integrity-bound reference.

fn get( &self, reference: &ArtifactRef, ) -> ArtifactFuture<'_, Result<Artifact, ArtifactError>>

Loads and verifies one artifact.

fn list( &self, scope: &ArtifactScope, after: Option<&str>, limit: u32, ) -> ArtifactFuture<'_, Result<ArtifactPage, ArtifactError>>

Lists one stable, bounded page inside one scope.

fn delete( &self, scope: &ArtifactScope, artifact_id: &str, ) -> ArtifactFuture<'_, Result<bool, ArtifactError>>

Idempotently deletes one artifact and its idempotency records.

fn purge_expired( &self, scope: &ArtifactScope, now_unix_ms: u64, limit: u32, ) -> ArtifactFuture<'_, Result<u32, ArtifactError>>

Deletes at most limit expired artifacts in one scope.

impl CheckpointStore for SqliteStore

fn load(&self, id: CheckpointId) -> Result<Checkpoint, CheckpointError>

Loads the latest checkpoint revision.

fn compare_and_swap( &self, checkpoint: &Checkpoint, expected_revision: Option<u64>, ) -> Result<(), CheckpointError>

Creates or atomically replaces a checkpoint.

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConversationStore for SqliteStore

fn create( &self, conversation_id: ConversationId, namespace: MemoryNamespace, ) -> ConversationStoreFuture<'_, Result<ConversationCreateOutcome, ConversationStoreError>>

Idempotently creates one empty conversation.

fn load_view( &self, conversation_id: ConversationId, namespace: MemoryNamespace, window: ConversationWindow, summary_batch: ConversationSummaryBatch, ) -> ConversationStoreFuture<'_, Result<ConversationView, ConversationStoreError>>

Loads a bounded view without deleting or rewriting transcript entries.

fn list_transcript( &self, conversation_id: ConversationId, namespace: MemoryNamespace, after: Option<ConversationSequence>, limit: ConversationWindow, ) -> ConversationStoreFuture<'_, Result<Vec<ConversationTranscriptEntry>, ConversationStoreError>>

Lists immutable transcript entries strictly after an optional sequence.

fn append( &self, namespace: MemoryNamespace, command: ConversationAppend, ) -> ConversationStoreFuture<'_, Result<ConversationVersion, ConversationStoreError>>

Atomically appends canonical messages under the expected version.

fn commit_summary( &self, namespace: MemoryNamespace, command: ConversationSummaryCommit, ) -> ConversationStoreFuture<'_, Result<ConversationSummary, ConversationStoreError>>

Monotonically replaces the lossy summary under the expected transcript version.

fn upsert_memory( &self, command: SemanticMemoryUpsert, ) -> ConversationStoreFuture<'_, Result<SemanticMemory, ConversationStoreError>>

Creates or compare-and-swaps one explicitly curated semantic memory.

fn search_memory( &self, query: SemanticMemoryQuery, ) -> ConversationStoreFuture<'_, Result<Vec<SemanticMemory>, ConversationStoreError>>

Searches semantic memory without reading transcript or journal storage.

fn upsert_memory_scoped( &self, command: SemanticMemoryUpsert, context: RetrievalContext, ) -> Pin<Box<dyn Future<Output = Result<SemanticMemoryUpsertOutcome, ConversationStoreError>> + Send + '_>>

Writes memory under an explicit cancellation/deadline scope.

fn search_memory_scoped( &self, query: SemanticMemoryQuery, context: RetrievalContext, ) -> Pin<Box<dyn Future<Output = Result<SemanticMemorySearchOutcome, ConversationStoreError>> + Send + '_>>

Searches memory under an explicit cancellation/deadline scope.

impl Debug for SqliteStore

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

Formats the value using the given formatter.

impl DurableConversationStore for SqliteStore

fn commit_durable_turn( &self, command: DurableConversationCommit, ) -> ConversationStoreFuture<'_, Result<ConversationVersion, ConversationStoreError>>

Atomically appends a transcript turn and advances its checkpoint.

impl EffectStore for SqliteStore

fn load( &self, id: EffectId, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Loads a record by effect identity.

fn find_by_idempotency( &self, capability_id: CapabilityId, key: &str, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Resolves a logical effect by capability-scoped idempotency key.

fn compare_and_swap( &self, record: &EffectRecord, expected_revision: Option<u64>, ) -> Result<(), EffectExecutorError>

Creates or atomically replaces a record.

impl Journal for SqliteStore

fn record(&self, event: &RunEvent) -> Result<(), JournalError>

Records one event.