Skip to main content

missing_blob_diagnostics

mz_persist_client::fetch

Function missing_blob_diagnostics 

Source 
pub(crate) async fn missing_blob_diagnostics<K, V, T, D>(
    applier: &Applier<K, V, T, D>,
    reader_id: LeasedReaderId,
) -> MissingBlobDiagnosis
where
    K: Debug + Codec,
    V: Debug + Codec,
    T: Timestamp + Lattice + Codec64 + Sync,
    D: Monoid + Codec64,
Expand description

Diagnoses a missing-blob fetch failure: refreshes the shard state and reports whether the reader that leased the part is still present in it.

A missing blob means garbage collection deleted a blob that the part’s lease (a seqno hold in shard state) should have protected. See MissingBlobDiagnosis for what each outcome means.