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.
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>
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".