pub fn start_worker_info_monitor(
metadata_manager: MetadataManager,
election_client: ElectionClientRef,
interval: Duration,
meta_metrics: Arc<MetaMetrics>,
) -> (JoinHandle<()>, Sender<()>)
pub fn start_worker_info_monitor(
metadata_manager: MetadataManager,
election_client: ElectionClientRef,
interval: Duration,
meta_metrics: Arc<MetaMetrics>,
) -> (JoinHandle<()>, Sender<()>)