Struct mz_persist::indexed::encoding::TraceBatchMeta
source · pub struct TraceBatchMeta {
pub keys: Vec<String>,
pub format: ProtoBatchFormat,
pub desc: Description<u64>,
pub level: u64,
pub size_bytes: u64,
}
Expand description
The metadata necessary to reconstruct a list of BlobTraceBatchParts.
Invariants:
- The Description’s time interval is non-empty.
- Keys for all trace batch parts are unique.
- Keys for all trace batch parts are stored in index order.
- The data in all of the trace batch parts is sorted and consolidated.
- All of the trace batch parts have the same desc as the metadata.
Fields§
§keys: Vec<String>
The keys to retrieve the batch’s data from the blob store.
The set of keys can be empty to denote an empty batch.
format: ProtoBatchFormat
The format of the stored batch data.
desc: Description<u64>
The half-open time interval [lower, upper)
this batch contains data
for.
level: u64
The compaction level of each batch.
size_bytes: u64
Size of the encoded batch.
Implementations§
source§impl TraceBatchMeta
impl TraceBatchMeta
sourcepub fn validate(&self) -> Result<(), Error>
pub fn validate(&self) -> Result<(), Error>
Asserts Self’s documented invariants, returning an error if any are violated.
sourcepub async fn validate_data(
&self,
blob: &dyn Blob,
metrics: &ColumnarMetrics,
) -> Result<(), Error>
pub async fn validate_data( &self, blob: &dyn Blob, metrics: &ColumnarMetrics, ) -> Result<(), Error>
Assert that all of the BlobTraceBatchPart’s obey the required invariants.
Trait Implementations§
source§impl Clone for TraceBatchMeta
impl Clone for TraceBatchMeta
source§fn clone(&self) -> TraceBatchMeta
fn clone(&self) -> TraceBatchMeta
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for TraceBatchMeta
impl Debug for TraceBatchMeta
source§impl PartialEq for TraceBatchMeta
impl PartialEq for TraceBatchMeta
impl Eq for TraceBatchMeta
impl StructuralPartialEq for TraceBatchMeta
Auto Trait Implementations§
impl Freeze for TraceBatchMeta
impl RefUnwindSafe for TraceBatchMeta
impl Send for TraceBatchMeta
impl Sync for TraceBatchMeta
impl Unpin for TraceBatchMeta
impl UnwindSafe for TraceBatchMeta
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp 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
.