Struct ConfigWatcher 

pub struct ConfigWatcher<T>
where
    T: DeserializeOwned + Clone + Send + Sync + 'static,
{ /* private fields */ }

Hot-reload configuration watcher

Watches a configuration file for changes and automatically reloads it. Validates new configurations before applying them.

Type Parameters

• T - The configuration type (must implement DeserializeOwned + Clone + Send + Sync)

Example

use mecha10::config_watcher::ConfigWatcher;
use serde::Deserialize;

#[derive(Debug, Clone, Deserialize)]
struct AppConfig {
    port: u16,
    debug: bool,
}

let watcher = ConfigWatcher::new("config.yaml", |config: &AppConfig| {
    println!("Port changed to: {}", config.port);
})?;

// Get current config
let config = watcher.get();

Implementations

impl<T> ConfigWatcher<T>

where T: DeserializeOwned + Clone + Send + Sync + 'static,

pub fn new<P, F>(path: P, on_change: F) -> Result<Self>

where P: AsRef<Path>, F: Fn(&T) + Send + Sync + 'static,

Create a new configuration watcher

Arguments

• path - Path to configuration file
• on_change - Callback invoked when configuration changes

Returns

A new ConfigWatcher instance

Errors

Returns error if:

• File doesn’t exist
• Initial configuration is invalid
• File watcher can’t be created

Example

let watcher = ConfigWatcher::new("config.yaml", |config: &MyConfig| {
    // Handle configuration change
    println!("Config updated!");
})?;

pub fn get(&self) -> T

Get the current configuration

Returns a clone of the current configuration.

Example

let config = watcher.get();
println!("Current rate: {}", config.rate);

pub async fn get_async(&self) -> T

Get the current configuration asynchronously

Returns a clone of the current configuration.

Example

let config = watcher.get_async().await;
println!("Current rate: {}", config.rate);

pub async fn reload(&self) -> Result<()>

Manually reload the configuration

Forces a reload of the configuration from disk.

Returns

Ok(()) if reload succeeded, Err if loading or validation failed

Example

watcher.reload().await?;

pub fn path(&self) -> &Path

Get the path to the configuration file