Struct WatcherHandle 

pub struct WatcherHandle {
    pub directory: PathBuf,
    pub table: String,
    pub target_db: Option<String>,
    pub stats: Arc<Mutex<WatcherStats>>,
    /* private fields */
}

Owns the notify watcher, the async ingest task, and the connection pool for one watched directory.

Dropping the handle stops the watcher cleanly: the Option<Watcher> is taken first, which drops the sender end of the mpsc channel, which causes the worker task’s recv() to return None, which ends the loop. We then abort the task just in case (the JoinHandle is dropped non-blockingly — the task has no cancellation-point awaits after recv()’s loop ends so it completes naturally).

Fields

directory: PathBuf

table: String

target_db: Option<String>

Resolved target database alias for this watcher. None → primary; Some("persistent") → persistent attachment; Some(alias) → user-attached writable. Stored so the post-reconnect rebuild path resolves to the same target, and so detach_database can refuse to detach an alias with an active watcher.

stats: Arc<Mutex<WatcherStats>>

Trait Implementations

impl Debug for WatcherHandle

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

Formats the value using the given formatter.

impl Drop for WatcherHandle

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.