Struct mz_persist_client::iter::FetchData

pub(crate) struct FetchData<T> {
    run_meta: RunMeta,
    part_desc: Description<T>,
    part: RunPart<T>,
    structured_lower: Option<ArrayBound>,
}

The data needed to fetch a batch part, bundled up to make it easy to send between threads.

Fields

run_meta: RunMeta

part_desc: Description<T>

part: RunPart<T>

structured_lower: Option<ArrayBound>

Implementations

impl<T: Codec64 + Timestamp + Lattice> FetchData<T>

async fn fetch( self, shard_id: ShardId, blob: &dyn Blob, metrics: &Metrics, shard_metrics: &ShardMetrics, read_metrics: &ReadMetrics, ) -> Result<Result<EncodedPart<T>, HollowRun<T>>>

Trait Implementations

impl<T: Clone> Clone for FetchData<T>

fn clone(&self) -> FetchData<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for FetchData<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.