Function mz_persist_client::fetch::fetch_leased_part
source · pub(crate) async fn fetch_leased_part<K, V, T, D>(
cfg: &PersistConfig,
part: &LeasedBatchPart<T>,
blob: &dyn Blob,
metrics: Arc<Metrics>,
read_metrics: &ReadMetrics,
shard_metrics: &ShardMetrics,
reader_id: &LeasedReaderId,
schemas: Schemas<K, V>,
) -> FetchedPart<K, V, T, D> ⓘ
Expand description
Trade in an exchange-able LeasedBatchPart for the data it represents.
Note to check the LeasedBatchPart
documentation for how to handle the
returned value.