Struct ConfigHotReload 

pub struct ConfigHotReload {

    active_config: Arc<RwLock<AirConfiguration>>,
    previous_config: Arc<RwLock<Option<AirConfiguration>>>,
    last_config_hash: Arc<RwLock<Option<String>>>,
    config_path: PathBuf,
    watcher: Option<Arc<RwLock<RecommendedWatcher>>>,
    change_sender: Sender<ConfigChangeEvent>,
    reload_tx: Sender<ReloadRequest>,
    change_history: Arc<RwLock<Vec<ConfigChangeRecord>>>,
    last_reload: Arc<RwLock<Option<DateTime<Utc>>>>,
    last_reload_duration: Arc<RwLock<Option<Duration>>>,
    enabled: Arc<RwLock<bool>>,
    debounce_delay: Duration,
    last_change_time: Arc<RwLock<Option<Instant>>>,
    stats: Arc<RwLock<ReloadStats>>,
    validators: Arc<RwLock<Vec<Box<dyn ConfigValidator>>>>,
    max_retries: u32,
    retry_delay: Duration,
    auto_rollback_enabled: Arc<RwLock<bool>>,
}

Configuration hot-reload manager with file watching and validation

Fields

active_config: Arc<RwLock<AirConfiguration>>

Current active configuration

previous_config: Arc<RwLock<Option<AirConfiguration>>>

Previous configuration for rollback

last_config_hash: Arc<RwLock<Option<String>>>

Last successful configuration hash

config_path: PathBuf

Configuration file path

watcher: Option<Arc<RwLock<RecommendedWatcher>>>

File watcher for monitoring changes

change_sender: Sender<ConfigChangeEvent>

Change notification sender for subscribers

reload_tx: Sender<ReloadRequest>

Reload request channel (for signal handling and manual triggers)

change_history: Arc<RwLock<Vec<ConfigChangeRecord>>>

Change history for auditing

last_reload: Arc<RwLock<Option<DateTime<Utc>>>>

Last reload timestamp

last_reload_duration: Arc<RwLock<Option<Duration>>>

Last reload duration

enabled: Arc<RwLock<bool>>

Whether hot-reload is enabled

debounce_delay: Duration

Reload debounce delay to prevent rapid successive reloads

last_change_time: Arc<RwLock<Option<Instant>>>

Last file change timestamp (for debouncing)

stats: Arc<RwLock<ReloadStats>>

Reload statistics

validators: Arc<RwLock<Vec<Box<dyn ConfigValidator>>>>

Validation callbacks

max_retries: u32

Maximum retry attempts for failed reloads

retry_delay: Duration

Retry delay with exponential backoff

auto_rollback_enabled: Arc<RwLock<bool>>

Whether automatic rollback is enabled on validation failure

Implementations

impl ConfigHotReload

pub async fn New( config_path: PathBuf, initial_config: AirConfiguration, ) -> Result<Self>

Create a new hot-reload manager

Arguments

• config_path - Path to the configuration file to monitor
• initial_config - Initial configuration to load

Returns

New ConfigHotReload instance with validation chain initialized

fn DefaultValidators() -> Vec<Box<dyn ConfigValidator>>

Get the default set of validators

pub async fn EnableFileWatching(&mut self) -> Result<()>

Enable file watching for configuration changes

pub async fn DisableFileWatching(&mut self) -> Result<()>

Disable file watching

fn StartReloadProcessor(&self, reload_rx: Receiver<ReloadRequest>)

Start the reload request processor

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

Reload configuration from file with retry logic and rollback support

async fn AttemptReload(&self) -> Result<()>

Attempt to reload configuration (single attempt)

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

Reload and validate configuration (alias for Reload)

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

Trigger a manual reload

async fn ValidateConfig(&self, config: &AirConfiguration) -> Result<()>

Validate configuration using all registered validators

pub async fn RegisterValidator(&self, validator: Box<dyn ConfigValidator>)

Register a custom validator

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

Rollback to previous configuration

pub async fn GetConfig(&self) -> AirConfiguration

Get current configuration

pub async fn GetConfigRef(&self) -> RwLockReadGuard<'_, AirConfiguration>

Get current configuration (read-only, non-copying)

pub async fn SetValue(&self, path: &str, value: &str) -> Result<()>

Set configuration value by path (e.g., “grpc.bind_address”)

pub async fn GetValue(&self, path: &str) -> Result<Value>

Get configuration value by path

fn SetConfigValue( config: &mut AirConfiguration, path: &str, value: &str, ) -> Result<()>

Set a nested configuration value

fn ComputeChanges( &self, old: &AirConfiguration, new: &AirConfiguration, ) -> Vec<ConfigChange>

Compute configuration changes

fn DiffJson( prefix: &str, old: &Value, new: &Value, changes: &mut Vec<ConfigChange>, )

Recursively diff JSON objects

pub async fn GetChangeHistory( &self, limit: Option<usize>, ) -> Vec<ConfigChangeRecord>

Get change history

pub async fn GetLastReload(&self) -> Option<DateTime<Utc>>

Get last reload timestamp

pub async fn GetLastReloadDuration(&self) -> Option<Duration>

Get last reload duration

pub async fn GetStats(&self) -> ReloadStats

Get reload statistics

pub async fn IsEnabled(&self) -> bool

Check if hot-reload is enabled

pub async fn SetAutoRollback(&self, enabled: bool)

Set whether auto-rollback is enabled

pub fn SubscribeChanges(&self) -> Receiver<ConfigChangeEvent>

Get configuration change event receiver

This can be used to subscribe to configuration change notifications

pub fn GetConfigPath(&self) -> &Path

Get configuration path

pub async fn SetDebounceDelay(&self, delay: Duration)

Set debounce delay