Struct Watcher 

pub struct Watcher { /* private fields */ }

File watcher for monitoring codebase changes.

The Watcher spawns a background task that monitors the specified directory and emits events via a channel. Events are consumed by the incremental indexer for hot-reload capability.

Implementations

impl Watcher

pub fn new( store: Arc<UnifiedGraphStore>, sender: UnboundedSender<WatchEvent>, ) -> Watcher

Creates a new watcher instance.

Arguments

• store - The graph store for event correlation
• sender - Channel to send watch events

pub async fn start(&self, path: PathBuf) -> Result<(), Error>

Starts watching the specified directory.

Spawns a background task that recursively watches the directory and emits events for file system changes.

Arguments

• path - Directory path to watch

Returns

Ok(()) if watching started successfully, or an error.

Errors

Returns an error if the directory cannot be watched.

pub fn channel() -> (UnboundedSender<WatchEvent>, UnboundedReceiver<WatchEvent>)

Creates a new channel pair for watch events.

Returns

A tuple of (sender, receiver) for watch events.

Trait Implementations

impl Clone for Watcher

fn clone(&self) -> Watcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Watcher

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

Formats the value using the given formatter.