vector::config::watcher

Function spawn_thread

Source 
pub fn spawn_thread<'a>(
    watcher_conf: WatcherConfig,
    signal_tx: SignalTx,
    config_paths: impl IntoIterator<Item = &'a PathBuf> + 'a,
    component_configs: Vec<ComponentConfig>,
    delay: impl Into<Option<Duration>>,
) -> Result<(), Error>
Expand description

Sends a ReloadFromDisk or ReloadEnrichmentTables on config_path changes. Accumulates file changes until no change for given duration has occurred. Has best effort guarantee of detecting all file changes from the end of this function until the main thread stops.