Struct ConfigWatcher 

pub struct ConfigWatcher { /* private fields */ }

Watches a ReloadableConfig<IndexerConfig> on a fixed polling interval and fires registered callbacks whenever the config changes.

Implementations

impl ConfigWatcher

pub fn new(interval: Duration) -> Self

Create a new ConfigWatcher that polls every interval.

pub fn watch( &self, config: Arc<RwLock<ReloadableConfig<IndexerConfig>>>, _source: ConfigSource, )

Start watching config for changes originating from source.

Spawns a background tokio task that compares version numbers and invokes all registered callbacks with the diffs when a change is detected.

pub async fn on_change( &self, callback: Box<dyn Fn(Vec<ConfigDiff>) + Send + Sync>, )

Register a callback to be invoked with the diffs on every detected change.

pub fn stop(&self)

Stop the background watcher task.