pub trait IndexStore: Send + Sync {
Show 27 methods
// Required methods
fn index_statuses(&self) -> StorageFuture<'_, Vec<IndexStatus>>;
fn mark_refresh_complete(
&self,
kind: IndexKind,
graph_version: GraphVersion,
) -> StorageFuture<'_, IndexStatus>;
// Provided methods
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> { ... }
}Expand description
Derived index metadata contract.