Struct IndexRebuildManager 

pub struct IndexRebuildManager { /* private fields */ }

Manages background index rebuilding with status tracking and retry logic.

The manager maintains a queue of index rebuild tasks and processes them in the background. Tasks can be monitored via status() and retried via retry_failed().

Implementations

impl IndexRebuildManager

pub async fn new( storage: Arc<StorageManager>, schema_manager: Arc<SchemaManager>, config: IndexRebuildConfig, ) -> Result<IndexRebuildManager, Error>

Create a new IndexRebuildManager.

pub async fn schedule(&self, labels: Vec<String>) -> Result<Vec<String>, Error>

Schedule labels for background index rebuild.

Returns the task IDs for the scheduled rebuilds.

pub fn status(&self) -> Vec<IndexRebuildTask>

Get status of all tasks.

pub fn task_status(&self, task_id: &str) -> Option<IndexRebuildTask>

Get status of a specific task by ID.

pub fn is_index_building(&self, label: &str) -> bool

Check if a label has a pending or in-progress index rebuild.

pub async fn retry_failed(&self) -> Result<Vec<String>, Error>

Retry all failed tasks.

pub async fn cancel(&self, task_id: &str) -> Result<(), Error>

Cancel a pending task.

pub async fn cleanup_completed(&self) -> Result<usize, Error>

Remove completed/failed tasks from tracking.

pub fn start_background_worker( self: Arc<IndexRebuildManager>, shutdown_rx: Receiver<()>, ) -> JoinHandle<()>

Start background worker that processes pending tasks.

This spawns a tokio task that periodically checks for pending tasks and processes them.