Struct mz_persist_client::stats::SnapshotStats
source · pub struct SnapshotStats {
pub shard_id: ShardId,
pub num_updates: usize,
}
Expand description
Statistics about the contents of a shard as_of some time.
TODO: Add more stats here as they become necessary.
Fields§
§shard_id: ShardId
The shard these statistics are for.
num_updates: usize
An estimate of the count of updates in the shard.
This is an upper bound on the number of updates that persist_source would emit if you snapshot the source at the given as_of. The real number of updates, after consolidation, might be lower. It includes both additions and retractions.
NB: Because of internal persist compaction, the answer for a given as_of may change over time (as persist advances through Seqnos), but because compaction never results in more updates than the sum of the inputs, it can only go down.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for SnapshotStats
impl RefUnwindSafe for SnapshotStats
impl Send for SnapshotStats
impl Sync for SnapshotStats
impl Unpin for SnapshotStats
impl UnwindSafe for SnapshotStats
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
.