Struct ConfigWatcher 

pub struct ConfigWatcher { /* private fields */ }

Watches a config file for changes and broadcasts validated updates.

Subscribers receive new PipelineConfig values via a [broadcast::Receiver].

Panics

This type never panics.

Implementations

impl ConfigWatcher

pub fn new( path: PathBuf, ) -> Result<(Self, Receiver<PipelineConfig>), ConfigError>

Create a new ConfigWatcher for the given config file path.

Returns the watcher and a receiver for config change notifications. The initial config is not broadcast — use loader::load_from_file for the initial load.

Arguments

• path — Path to the TOML config file to watch.

Returns

• Ok((ConfigWatcher, Receiver)) on success.
• Err(ConfigError) if the file watcher cannot be created.

Panics

This function never panics.

Example

use tokio_prompt_orchestrator::config::watcher::ConfigWatcher;
use std::path::PathBuf;

let (watcher, mut rx) = ConfigWatcher::new(PathBuf::from("pipeline.toml"))?;
tokio::spawn(async move {
    while let Ok(config) = rx.recv().await {
        println!("Config reloaded: {}", config.pipeline.name);
    }
});

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

Subscribe to config change notifications.

Returns a new receiver. Multiple subscribers are supported.

Panics

This function never panics.