Struct IncrementalIndexer 

pub struct IncrementalIndexer { /* private fields */ }

Incremental indexer for processing file changes.

The IncrementalIndexer batches file system events and processes them on flush, avoiding full re-indexing of the codebase.

Examples

use forgekit_core::indexing::IncrementalIndexer;
use forgekit_core::watcher::WatchEvent;
use std::path::PathBuf;

let indexer = IncrementalIndexer::new(store);

// Queue some changes (only src/ and tests/ files will be indexed)
indexer.queue(WatchEvent::Modified(PathBuf::from("src/lib.rs")));
indexer.queue(WatchEvent::Created(PathBuf::from("tests/test.rs")));
indexer.queue(WatchEvent::Modified(PathBuf::from("target/debug/build.rs"))); // Ignored

// Process changes
indexer.flush().await?;

Implementations

impl IncrementalIndexer

pub fn new(store: Arc<UnifiedGraphStore>) -> Self

Creates a new incremental indexer with default path filtering.

By default, only files in src/ and tests/ directories are indexed.

Arguments

• store - The graph store for index updates

pub fn with_filter(store: Arc<UnifiedGraphStore>, filter: PathFilter) -> Self

Creates a new incremental indexer with a custom path filter.

Arguments

• store - The graph store for index updates
• filter - Custom path filter

pub fn filter(&self) -> &PathFilter

Returns a reference to the path filter.

pub fn set_filter(&mut self, filter: PathFilter)

Sets a new path filter.

pub fn queue(&self, event: WatchEvent)

Queues a watch event for processing.

Only files matching the path filter will be queued.

Arguments

• event - The watch event to queue

pub async fn flush(&self) -> Result<FlushStats>

Flushes pending changes to the graph store.

This method processes all queued file changes and updates the index incrementally.

Returns

Ok(()) if flush succeeded, or an error.

Errors

Returns an error if any file cannot be indexed.

pub async fn full_rescan(&self, root: &Path) -> Result<usize>

Performs a full rescan of the codebase.

This clears all pending changes and re-indexes from scratch, respecting the path filter.

Arguments

• root - The root directory to scan

Returns

Ok(count) with number of files indexed, or an error.

pub async fn pending_count(&self) -> usize

Returns the number of pending files to process.

pub async fn clear_pending(&self)

Clears all pending changes without processing.

Trait Implementations

impl Clone for IncrementalIndexer

fn clone(&self) -> IncrementalIndexer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IncrementalIndexer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.