Skip to main content

run_index_purge_task

Function run_index_purge_task 

Source
pub(crate) async fn run_index_purge_task(
    worker_id: u32,
    store: ObjectStore,
    receiver: UnboundedReceiver<PurgeRequest>,
)
Expand description

Processes queued deletions once each, independently of periodic maintenance.