pub trait CodeIndexTaskStore: Send + Sync {
Show 15 methods
// Required methods
fn queue_code_index_task(
&self,
task: CodeIndexTaskSeed,
) -> StorageFuture<'_, CodeIndexTaskRecord>;
fn claim_code_index_task(
&self,
request: CodeIndexTaskClaimRequest,
) -> StorageFuture<'_, Option<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>>;
// Provided methods
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 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 code_index_task_queue_status(
&self,
) -> StorageFuture<'_, CodeIndexTaskQueueStatus> { ... }
}Expand description
Durable task queue, attempt lease, retry, and completion capability.
Required Methods§
fn queue_code_index_task( &self, task: CodeIndexTaskSeed, ) -> StorageFuture<'_, CodeIndexTaskRecord>
fn claim_code_index_task( &self, request: CodeIndexTaskClaimRequest, ) -> StorageFuture<'_, Option<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>>
Provided Methods§
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 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 code_index_task_queue_status( &self, ) -> StorageFuture<'_, CodeIndexTaskQueueStatus>
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".