Enum mz_persist_client::iter::FetchData
source · pub(crate) enum FetchData<T> {
Unfetched {
part_desc: Description<T>,
part: BatchPart<T>,
},
AlreadyFetched,
}
Expand description
The data needed to fetch a batch part, bundled up to make it easy to send between threads.
Variants§
Implementations§
source§impl<T: Codec64 + Timestamp + Lattice> FetchData<T>
impl<T: Codec64 + Timestamp + Lattice> FetchData<T>
sourcefn wrong_sort(&self) -> bool
fn wrong_sort(&self) -> bool
Returns true iff we were using a different ordering for data or timestamps when the part was created. This means parts or runs may not be ordered according to our modern definition, even if the metadata indicates they’ve been compacted before.
fn take(&mut self) -> Self
fn key_lower(&self) -> &[u8] ⓘ
async fn fetch( self, shard_id: ShardId, blob: &dyn Blob, metrics: &Metrics, shard_metrics: &ShardMetrics, read_metrics: &ReadMetrics, ) -> Result<EncodedPart<T>>
Trait Implementations§
Auto Trait Implementations§
impl<T> !Freeze for FetchData<T>
impl<T> RefUnwindSafe for FetchData<T>where
T: RefUnwindSafe,
impl<T> Send for FetchData<T>where
T: Send,
impl<T> Sync for FetchData<T>where
T: Sync,
impl<T> Unpin for FetchData<T>where
T: Unpin,
impl<T> UnwindSafe for FetchData<T>where
T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.