Function mz_persist_client::read::fetch_batch_part
source · [−]pub(crate) async fn fetch_batch_part<T, UpdateFn>(
shard_id: &ShardId,
blob: &(dyn Blob + Send + Sync),
metrics: &Metrics,
key: &PartialBlobKey,
registered_desc: &Description<T>,
update_fn: UpdateFn
) -> Result<(), Error> where
T: Timestamp + Lattice + Codec64,
UpdateFn: FnMut(&[u8], &[u8], T, [u8; 8]),