Struct PartitionedSqliteKnowledgeStore 

pub struct PartitionedSqliteKnowledgeStore { /* private fields */ }

SQLite topology that keeps global control state in one DB and code facts in one DB per registered repository.

Implementations

impl PartitionedSqliteKnowledgeStore

pub fn has_active_catalog( control_path: impl AsRef<Path>, ) -> Result<bool, StorageError>

pub async fn topology_snapshot( &self, ) -> Result<StorageTopologySnapshot, StorageError>

pub fn topology_snapshot_from_catalog( control_path: impl AsRef<Path>, paths: &RuntimePaths, ) -> Result<StorageTopologySnapshot, StorageError>

impl PartitionedSqliteKnowledgeStore

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

Trait Implementations

impl BusinessKnowledgeStore for PartitionedSqliteKnowledgeStore

fn replace_business_knowledge_projection( &self, input: BusinessKnowledgeProjectionInput, ) -> StorageFuture<'_, BusinessKnowledgeStatus>

fn replace_business_knowledge_projection_with_fence( &self, input: BusinessKnowledgeProjectionInput, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, BusinessKnowledgeStatus>

fn business_knowledge_projection_for_scope( &self, source_scope: String, request: BusinessKnowledgeQueryRequest, ) -> StorageFuture<'_, BusinessKnowledgeProjection>

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

impl Clone for PartitionedSqliteKnowledgeStore

fn clone(&self) -> PartitionedSqliteKnowledgeStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CodeGraphStore for PartitionedSqliteKnowledgeStore

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 CodeIndexPublicationStore for PartitionedSqliteKnowledgeStore

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

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

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

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

fn clear_code_workspace_state( &self, repository_id: String, source_scope: String, ) -> StorageFuture<'_, ()>

fn code_repository_auto_workspace_state_exists( &self, repository_id: String, ) -> StorageFuture<'_, bool>

Reports whether repository-owned auto-detected workspace artifacts still exist and therefore require a durable disabled-mode cleanup.

fn clear_code_workspace_state_with_fence( &self, repository_id: String, source_scope: String, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, ()>

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

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

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

Starts a checkpointed session only when the durable checkpoint still matches the value observed during read-only plan validation.

fn begin_code_index_session_at_checkpoint_with_fence( &self, session: CodeIndexSession, expected_checkpoint: Option<CodeIndexCheckpoint>, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, CodeIndexCheckpoint>

Fenced variant of CodeIndexPublicationStore::begin_code_index_session_at_checkpoint.

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

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

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

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

fn advance_code_index_session_with_fence( &self, session: CodeIndexSession, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, CodeIndexFinalizationStep>

impl CodeIndexSourceStore for PartitionedSqliteKnowledgeStore

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>, exclude_generated: bool, 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>, exclude_generated: bool, limit: usize, ) -> StorageFuture<'_, Vec<String>>

fn repository_documents_for_scope( &self, source_scope: String, path_filters: Vec<String>, max_files: usize, max_bytes: usize, ) -> StorageFuture<'_, Vec<IndexedRepositoryDocument>>

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

impl CodeIndexTaskStore for PartitionedSqliteKnowledgeStore

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 running_code_index_task_leases( &self, ) -> StorageFuture<'_, Vec<CodeIndexTaskLeaseRecord>>

fn recover_code_index_task_leases_by_task( &self, request: CodeIndexTaskLeaseRecovery, ) -> StorageFuture<'_, usize>

fn reset_code_index_tasks( &self, repository_id: String, now_ms: u64, ) -> StorageFuture<'_, Vec<CodeIndexTaskRecord>>

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

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

fn run_code_index_post_maintenance( &self, repository_id: String, source_scope: String, ) -> StorageFuture<'_, ()>

fn code_index_publication_receipt( &self, task_id: String, repository_id: String, source_scope: String, now_ms: u64, ) -> StorageFuture<'_, bool>

fn reconcile_code_index_publication_with_fence( &self, target: CodeIndexPublicationTarget, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, bool>

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_task_queue_status( &self, ) -> StorageFuture<'_, CodeIndexTaskQueueStatus>

impl CodeQueryReadStore for PartitionedSqliteKnowledgeStore

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

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

fn search_code_feature_flags_scope( &self, source_scope: String, 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 analyze_code_impact_scope( &self, source_scope: String, request: CodeImpactRequest, changes: CodeImpactChanges, ) -> StorageFuture<'_, Vec<CodeRetrievalHit>>

fn codebase_view_snapshot( &self, source_scope: String, request: CodebaseViewRequest, row_limit: usize, ) -> StorageFuture<'_, CodebaseViewSnapshot>

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

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

fn code_repository_scope_symbol_generation_counts( &self, source_scope: String, ) -> StorageFuture<'_, CodeSymbolGenerationCounts>

impl CodeRepositorySetStore for PartitionedSqliteKnowledgeStore

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, _publication: CodeRepositorySetRefreshPublication, ) -> StorageFuture<'_, CodeRepositorySetRefreshSummary>

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

fn code_repository_set_cross_edges_for_selector( &self, set_id: String, selector: CodeRepositorySetEdgeSelector, ) -> 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 CodeScopeRetentionStore for PartitionedSqliteKnowledgeStore

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

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

fn schedule_code_repository_retention( &self, max_indexed_repositories: usize, now_ms: u64, ) -> StorageFuture<'_, Option<String>>

fn code_repository_retention_scan_pending(&self) -> StorageFuture<'_, bool>

impl FrameworkGraphStore for PartitionedSqliteKnowledgeStore

fn search_framework_graph( &self, request: FrameworkGraphRequest, ) -> StorageFuture<'_, FrameworkGraph>

fn search_framework_graph_scope( &self, source_scope: String, request: FrameworkGraphRequest, ) -> StorageFuture<'_, FrameworkGraph>

impl GraphStore for PartitionedSqliteKnowledgeStore

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

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

fn health_snapshot( &self, now_ms: u64, ) -> StorageFuture<'_, HealthStorageSnapshot>

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

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

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

impl IndexStore for PartitionedSqliteKnowledgeStore

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_count( &self, state: Option<ProposalState>, ) -> StorageFuture<'_, usize>

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 search_file_content( &self, request: FileContentSearchRequest, ) -> StorageFuture<'_, Vec<FileContentSearchHit>>

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

impl MutationLogStore for PartitionedSqliteKnowledgeStore

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

impl RepositoryCatalogStore for PartitionedSqliteKnowledgeStore

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

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

fn list_code_repositories(&self) -> StorageFuture<'_, Vec<CodeRepositoryStatus>>

fn remove_code_repository( &self, repository: String, now_ms: u64, ) -> StorageFuture<'_, Option<CodeRepositoryRemovalSummary>>

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

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

impl SoftwareProjectionStore for PartitionedSqliteKnowledgeStore

fn refresh_software_global_projection( &self, source_scope: String, ) -> StorageFuture<'_, SoftwareGlobalProjection>

fn refresh_software_global_projection_with_fence( &self, source_scope: String, fence: CodeIndexPublicationFence, ) -> StorageFuture<'_, SoftwareGlobalProjection>

fn software_global_projection( &self, request: SoftwareGlobalRequest, ) -> StorageFuture<'_, SoftwareGlobalProjection>

fn software_global_projection_for_scope( &self, source_scope: String, request: SoftwareGlobalRequest, ) -> StorageFuture<'_, SoftwareGlobalProjection>