Struct ConfigWatcher 

pub struct ConfigWatcher { /* private fields */ }

Watches a config file for changes and broadcasts new configs via a watch channel.

Uses tokio::fs::metadata() polling to detect modification time changes. When a change is detected, the file is re-read, parsed, and validated. Only valid configs are broadcast; invalid files log a warning and are skipped.

Implementations

impl ConfigWatcher

pub fn new(config_path: PathBuf, poll_interval: Duration) -> Result<Self>

Create a new watcher for the given config file.

Loads the initial config immediately and makes it available via subscribe().

pub fn from_config( config_path: PathBuf, poll_interval: Duration, config: AgentZeroConfig, ) -> Self

Create a watcher from an already-loaded config (avoids double-load at startup).

pub fn subscribe(&self) -> Receiver<AgentZeroConfig>

Get a receiver to subscribe to config changes.

pub fn current(&self) -> AgentZeroConfig

Get the current config snapshot.

pub async fn run(self, cancel: Receiver<bool>)

Run the polling loop. This is a long-running task — spawn it with tokio::spawn.

The loop runs until the sender is dropped (all receivers dropped) or the token signals cancellation.