Function mz_adapter::coord::sequencer::inner::check_log_reads

source ยท
pub(super) fn check_log_reads(
    catalog: &Catalog,
    cluster: &Cluster,
    source_ids: &BTreeSet<GlobalId>,
    target_replica: &mut Option<ReplicaId>,
    vars: &SessionVars,
) -> Result<impl IntoIterator<Item = AdapterNotice>, AdapterError>
Expand description

Checks whether we should emit diagnostic information associated with reading per-replica sources.

If an unrecoverable error is found (today: an untargeted read on a cluster with a non-1 number of replicas), return that. Otherwise, return a list of associated notices (today: we always emit exactly one notice if there are any per-replica log dependencies and if emit_introspection_query_notice is set, and none otherwise.)