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.

Struct mz_persist_client::stats::SnapshotStatsCopy item path

Fields§

Trait Implementations§

impl Debug for SnapshotStats

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

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§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T, U> CastInto<U> for Twhere U: CastFrom<T>,

fn cast_into(self) -> U

impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for Twhere R: Region<Index = (usize, usize)>, O: OffsetContainer<usize>, T: CopyOnto<R>,

fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> Pointable for T

const ALIGN: usize = _

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,

fn into_rust(self) -> Result<R, TryFromProtoError>

fn from_rust(rust: &R) -> P

impl<R, T> PushInto<FlatStack<R>> for Twhere R: Region + Clone + 'static, T: CopyOnto<R>,

fn push_into(self, target: &mut FlatStack<R>)

impl<T> PushInto<Vec<T>> for T

fn push_into(self, target: &mut Vec<T>)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct mz_persist_client::stats::SnapshotStats

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> CastInto<U> for T
where U: CastFrom<T>,

impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
where R: Region<Index = (usize, usize)>, O: OffsetContainer<usize>, T: CopyOnto<R>,

impl<T, U> Into<U> for T
where U: From<T>,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

impl<P, R> ProtoType<R> for P
where R: RustType<P>,

impl<R, T> PushInto<FlatStack<R>> for T
where R: Region + Clone + 'static, T: CopyOnto<R>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,