Function mz_storage_client::controller::statistics::spawn_statistics_scraper
source · pub(super) fn spawn_statistics_scraper<Stats, T>(
statistics_collection_id: GlobalId,
collection_mgmt: CollectionManager<T>,
shared_stats: Arc<Mutex<BTreeMap<GlobalId, StatsInitState<Stats>>>>
) -> Box<dyn Any + Send + Sync>where
Stats: PackableStats + Debug + Send + 'static,
T: Timestamp + Lattice + Codec64 + From<EpochMillis> + TimestampManipulation,
Expand description
Spawns a task that continually (at an interval) writes statistics from storaged’s that are consolidated in shared memory in the controller.