Struct HotReloadManager 

pub struct HotReloadManager { /* private fields */ }

Central coordinator for all hot-reload operations.

Holds one ReloadableConfig<IndexerConfig> per registered indexer ID, and a watch channel per config so subscribers are notified on every version bump.

Implementations

impl HotReloadManager

pub fn new() -> Self

Create a new, empty HotReloadManager.

pub async fn register_config( &self, id: &str, config: IndexerConfig, ) -> Arc<RwLock<ReloadableConfig<IndexerConfig>>>

Register a new indexer config under id.

Returns a shared handle to the ReloadableConfig so the caller can read the current value cheaply without going through the manager.

pub async fn update_config( &self, id: &str, new_config: IndexerConfig, ) -> Result<ReloadResult, IndexerError>

Apply new_config to the indexer identified by id.

The update is validated first; if validation fails the existing config is left unchanged and an Err is returned.

pub async fn get_config(&self, id: &str) -> Option<IndexerConfig>

Return a clone of the current IndexerConfig for id, or None if id is not registered.

pub async fn get_version(&self, id: &str) -> Option<u64>

Return the current version number for id, or None if not registered.

pub async fn subscribe(&self, id: &str) -> Option<Receiver<u64>>

Return a watch::Receiver that yields the new version on every reload.

Returns None if id is not registered.

pub async fn configs(&self) -> Vec<String>

List all registered config IDs.

pub async fn history(&self, id: &str) -> Vec<ReloadRecord>

Return the full reload history for id.

Trait Implementations

impl Default for HotReloadManager

fn default() -> Self

Returns the “default value” for a type.