Struct FileWatcher 

pub struct FileWatcher { /* private fields */ }

Lightweight wrapper around notify for watching .sqry-index files.

Implementations

impl FileWatcher

pub fn new() -> SessionResult<Self>

Create an active file watcher.

Errors

Returns SessionError when the underlying notify watcher cannot be initialised.

pub fn disabled() -> Self

Create a disabled watcher (used when file watching is turned off).

pub fn watch<F>(&mut self, path: PathBuf, on_change: F) -> SessionResult<()>

where F: Fn() + Send + Sync + 'static,

Register a workspace path for change notifications.

When the underlying .sqry-index file changes, on_change is invoked.

Errors

Returns SessionError when the watcher cannot register the path.

pub fn unwatch(&mut self, path: &Path) -> SessionResult<()>

Stop watching a workspace path.

Errors

Returns SessionError when the watcher fails to unregister the path.

pub fn process_events(&mut self) -> SessionResult<()>

Drain pending filesystem events and invoke registered callbacks.

Errors

Returns SessionError when event processing fails catastrophically (e.g., callback errors).

pub fn wait_and_process(&mut self, duration: Duration) -> SessionResult<()>

Wait for a duration while processing events

Unlike thread::sleep() followed by process_events(), this actively drains and processes events during the wait period. This is crucial for macOS FSEvents which may deliver batched notifications with higher latency.

Reference: CI_FAILURE_REMEDIATION_PLAN.md Section 2

Errors

Returns SessionError when the event loop encounters an unrecoverable error.