Struct SqliteGraphStore 

pub struct SqliteGraphStore { /* private fields */ }

SQLite implementation of graph facts, mutation log, and index metadata.

Implementations

impl SqliteGraphStore

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

Opens a SQLite database and initializes the v1 schema.

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

Opens an in-memory database for isolated tests.

Trait Implementations

impl Clone for SqliteGraphStore

fn clone(&self) -> SqliteGraphStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CodeGraphStore for SqliteGraphStore

fn commit_code_graph_batch( &self, batch: CodeGraphBatch, ) -> StorageFuture<'_, CodeGraphCommitReceipt>

fn search_code_symbols( &self, request: CodeSymbolSearchRequest, ) -> StorageFuture<'_, Vec<CodeSymbolRecord>>

fn search_code_references( &self, request: CodeReferenceSearchRequest, ) -> StorageFuture<'_, Vec<CodeReferenceRecord>>

fn search_code_chunks( &self, request: CodeChunkSearchRequest, ) -> StorageFuture<'_, Vec<CodeChunkRecord>>

impl CodeRepositoryStore for SqliteGraphStore

fn upsert_code_repository( &self, registration: CodeRepositoryRegistration, ) -> StorageFuture<'_, CodeRepositoryStatus>

fn code_repository_status( &self, repository: String, ) -> StorageFuture<'_, Option<CodeRepositoryStatus>>

fn code_repository_scope_status( &self, repository: String, resolved_commit_sha: String, path_filters: Vec<String>, language_filters: Vec<String>, ) -> StorageFuture<'_, Option<CodeRepositoryStatus>>

fn queue_code_index_task( &self, task: CodeIndexTaskSeed, ) -> StorageFuture<'_, CodeIndexTaskRecord>

fn claim_code_index_task( &self, request: CodeIndexTaskClaimRequest, ) -> StorageFuture<'_, Option<CodeIndexTaskRecord>>

fn recover_code_index_task_leases( &self, now_ms: u64, max_attempts: u32, ) -> StorageFuture<'_, ()>

fn renew_code_index_task_lease( &self, request: CodeIndexTaskLeaseRenewal, ) -> StorageFuture<'_, CodeIndexTaskRecord>

fn complete_code_index_task( &self, request: CodeIndexTaskCompletion, ) -> StorageFuture<'_, CodeIndexTaskRecord>

fn fail_code_index_task( &self, request: CodeIndexTaskFailure, ) -> StorageFuture<'_, CodeIndexTaskRecord>

fn code_index_task( &self, task_id: String, ) -> StorageFuture<'_, Option<CodeIndexTaskRecord>>

fn active_code_index_task( &self, repository_id: String, ) -> StorageFuture<'_, Option<CodeIndexTaskRecord>>

fn code_index_checkpoint( &self, source_scope: String, ) -> StorageFuture<'_, Option<CodeIndexCheckpoint>>

fn code_scope_retention( &self, repository_id: String, ) -> StorageFuture<'_, CodeScopeRetentionSummary>

fn prune_code_repository_scopes( &self, request: CodeScopeRetentionRequest, ) -> StorageFuture<'_, CodeScopeRetentionSummary>

fn code_file_fingerprints( &self, repository_id: String, ) -> StorageFuture<'_, Vec<CodeFileFingerprint>>

fn code_file_fingerprints_for_scope( &self, source_scope: String, ) -> StorageFuture<'_, Vec<CodeFileFingerprint>>

fn code_file_candidate_paths_for_scope( &self, source_scope: String, path_filters: Vec<String>, language_filters: Vec<String>, limit: usize, ) -> StorageFuture<'_, Vec<String>>

fn code_file_candidate_paths_for_query_scope( &self, source_scope: String, query: String, path_filters: Vec<String>, language_filters: Vec<String>, limit: usize, ) -> StorageFuture<'_, Vec<String>>

fn apply_code_index_snapshot( &self, snapshot: CodeIndexSnapshot, ) -> StorageFuture<'_, CodeIndexSummary>

fn begin_code_index_session( &self, session: CodeIndexSession, ) -> StorageFuture<'_, CodeIndexCheckpoint>

fn apply_code_index_batch( &self, batch: CodeIndexBatch, ) -> StorageFuture<'_, CodeIndexCheckpoint>

fn finalize_code_index_session( &self, session: CodeIndexSession, ) -> StorageFuture<'_, CodeIndexSummary>

fn search_code( &self, request: CodeRetrievalRequest, ) -> StorageFuture<'_, Vec<CodeRetrievalHit>>

fn search_code_feature_flags( &self, request: CodeFeatureFlagRequest, ) -> StorageFuture<'_, Vec<CodeFeatureFlagGraph>>

fn search_code_scope( &self, source_scope: String, request: CodeRetrievalRequest, ) -> StorageFuture<'_, Vec<CodeRetrievalHit>>

fn analyze_code_impact( &self, request: CodeImpactRequest, changes: CodeImpactChanges, ) -> StorageFuture<'_, Vec<CodeRetrievalHit>>

fn code_repository_totals(&self) -> StorageFuture<'_, CodeRepositoryTotals>

fn code_repository_report( &self, repository: String, ) -> StorageFuture<'_, CodeRepositoryReport>

fn create_code_repository_set( &self, seed: CodeRepositorySetSeed, ) -> StorageFuture<'_, CodeRepositorySet>

fn add_code_repository_set_member( &self, seed: CodeRepositorySetMemberSeed, ) -> StorageFuture<'_, CodeRepositorySetMember>

fn remove_code_repository_set_member( &self, set_alias: String, repository_alias: String, ) -> StorageFuture<'_, CodeRepositorySetMember>

fn code_repository_set( &self, set_alias: String, ) -> StorageFuture<'_, Option<CodeRepositorySet>>

fn code_repository_set_status( &self, set_alias: String, ) -> StorageFuture<'_, Option<CodeRepositorySetStatus>>

fn refresh_code_repository_set_overlay( &self, set_alias: String, now_ms: u64, ) -> StorageFuture<'_, CodeRepositorySetRefreshSummary>

fn code_repository_set_cross_edges( &self, set_id: String, ) -> StorageFuture<'_, Vec<CodeRepositoryCrossEdge>>

fn queue_code_repository_set_refresh_task( &self, task: CodeRepositorySetRefreshTaskSeed, ) -> StorageFuture<'_, CodeRepositorySetRefreshTaskRecord>

fn claim_code_repository_set_refresh_task( &self, request: CodeRepositorySetRefreshTaskClaimRequest, ) -> StorageFuture<'_, Option<CodeRepositorySetRefreshTaskRecord>>

fn complete_code_repository_set_refresh_task( &self, request: CodeRepositorySetRefreshTaskCompletion, ) -> StorageFuture<'_, CodeRepositorySetRefreshTaskRecord>

fn fail_code_repository_set_refresh_task( &self, request: CodeRepositorySetRefreshTaskFailure, ) -> StorageFuture<'_, CodeRepositorySetRefreshTaskRecord>

impl Debug for SqliteGraphStore

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

Formats the value using the given formatter.

impl GraphStore for SqliteGraphStore

fn commit_mutation_batch( &self, batch: GraphMutationBatch, ) -> StorageFuture<'_, CommitReceipt>

fn inspect_graph(&self) -> StorageFuture<'_, GraphInspection>

fn graph_canvas( &self, request: GraphCanvasStorageRequest, ) -> StorageFuture<'_, GraphCanvasStorageSnapshot>

fn search( &self, request: GraphSearchRequest, ) -> StorageFuture<'_, Vec<RetrievalHit>>

fn current_graph_version(&self) -> StorageFuture<'_, GraphVersion>

impl IndexStore for SqliteGraphStore

fn index_statuses(&self) -> StorageFuture<'_, Vec<IndexStatus>>

fn mark_refresh_complete( &self, kind: IndexKind, graph_version: GraphVersion, ) -> StorageFuture<'_, IndexStatus>

fn index_cursors(&self) -> StorageFuture<'_, Vec<IndexCursor>>

fn queue_index_refreshes( &self, request: IndexRefreshQueueRequest, ) -> StorageFuture<'_, IndexRefreshDiagnostics>

fn claim_index_refresh_task( &self, request: IndexRefreshClaimRequest, ) -> StorageFuture<'_, Option<IndexRefreshTask>>

fn complete_index_refresh_task( &self, request: IndexRefreshCompletion, ) -> StorageFuture<'_, IndexRefreshTask>

fn fail_index_refresh_task( &self, request: IndexRefreshFailure, ) -> StorageFuture<'_, IndexRefreshTask>

fn index_refresh_diagnostics( &self, now_ms: u64, ) -> StorageFuture<'_, IndexRefreshDiagnostics>

fn queue_worker_tasks( &self, tasks: Vec<WorkerTaskSeed>, ) -> StorageFuture<'_, Vec<WorkerTaskRecord>>

fn worker_statuses(&self) -> StorageFuture<'_, Vec<WorkerStatus>>

fn claim_worker_task( &self, request: WorkerTaskClaimRequest, ) -> StorageFuture<'_, Option<WorkerTaskRecord>>

fn complete_worker_task( &self, request: WorkerTaskCompletion, ) -> StorageFuture<'_, WorkerTaskRecord>

fn fail_worker_task( &self, request: WorkerTaskFailure, ) -> StorageFuture<'_, WorkerTaskRecord>

fn insert_proposal( &self, proposal: NewProposal, ) -> StorageFuture<'_, ProposalRecord>

fn list_proposals( &self, request: ProposalListRequest, ) -> StorageFuture<'_, Vec<ProposalRecord>>

fn proposal_by_id( &self, proposal_id: String, ) -> StorageFuture<'_, Option<ProposalRecord>>

fn proposal_conflicts( &self, proposal_id: String, ) -> StorageFuture<'_, Vec<ProposalConflictRecord>>

fn decide_proposal( &self, request: ProposalDecision, ) -> StorageFuture<'_, ProposalRecord>

fn insert_audit_event( &self, event: NewAuditEvent, ) -> StorageFuture<'_, AuditEventRecord>

fn query_audit_events( &self, request: AuditQueryRequest, ) -> StorageFuture<'_, Vec<AuditEventRecord>>

fn audit_event_count(&self) -> StorageFuture<'_, usize>

fn service_operator_status(&self) -> StorageFuture<'_, ServiceOperatorStatus>

fn update_service_operator( &self, request: ServiceOperatorUpdate, ) -> StorageFuture<'_, ServiceOperatorStatus>

fn replace_file_index_root( &self, update: FileIndexRootUpdate, ) -> StorageFuture<'_, FileIndexRootStatus>

fn mark_file_index_roots_unconfigured( &self, active_roots: Vec<FileIndexRoot>, now_ms: u64, ) -> StorageFuture<'_, FileIndexDiagnostics>

fn search_files( &self, request: FileSearchRequest, ) -> StorageFuture<'_, Vec<FileSearchHit>>

fn file_index_diagnostics(&self) -> StorageFuture<'_, FileIndexDiagnostics>

impl MutationLogStore for SqliteGraphStore

fn read_after( &self, graph_version: GraphVersion, limit: usize, ) -> StorageFuture<'_, Vec<MutationLogEntry>>