Skip to main content

run_config_reload_supervisor_with_observers

Function run_config_reload_supervisor_with_observers 

Source
pub async fn run_config_reload_supervisor_with_observers<N, R, RFut, F, Fut>(
    notifier: Arc<N>,
    config: ConfigReloadWorkerConfig,
    shutdown: CancellationToken,
    reconcile: R,
    reload: F,
    reload_observer: Option<&dyn ConfigReloadObserver>,
    connection_observer: Option<&dyn ConfigSyncConnectionObserver>,
) -> Result<()>
where N: ConfigChangeNotifier + ?Sized, R: FnMut() -> RFut, RFut: Future<Output = Result<()>>, F: FnMut(ConfigReloadMessage) -> Fut, Fut: Future<Output = Result<()>>,
Expand description

Runs a reconnecting reload subscription and reports reload and connection observations.