Function mz_storage::healthcheck::health_operator

pub(crate) fn health_operator<'g, G, P>(
    scope: &Child<'g, G, Timestamp>,
    now: NowFn,
    mark_starting: BTreeSet<GlobalId>,
    halting_id: GlobalId,
    object_type: &'static str,
    health_stream: &Stream<G, HealthStatusMessage>,
    configs: BTreeMap<usize, GlobalId>,
    health_operator_impl: P,
    write_namespaced_map: bool
) -> PressOnDropButtonwhere
    G: Scope<Timestamp = ()>,
    P: HealthOperator + 'static,

Writes updates that come across health_stream to the collection’s status shards, as identified by their CollectionMetadata.

Only one worker will be active and write to the status shard.

The OutputIndex values that come across health_stream must be a strict subset of thosema, configs’s keys.