Struct mz_persist_client::internal::metrics::CompactionMetrics
source · pub struct CompactionMetrics {Show 25 fields
pub(crate) requested: IntCounter,
pub(crate) dropped: IntCounter,
pub(crate) skipped: IntCounter,
pub(crate) started: IntCounter,
pub(crate) applied: IntCounter,
pub(crate) timed_out: IntCounter,
pub(crate) failed: IntCounter,
pub(crate) noop: IntCounter,
pub(crate) seconds: Counter,
pub(crate) concurrency_waits: IntCounter,
pub(crate) queued_seconds: Counter,
pub(crate) memory_violations: IntCounter,
pub(crate) runs_compacted: IntCounter,
pub(crate) chunks_compacted: IntCounter,
pub(crate) not_all_prefetched: IntCounter,
pub(crate) parts_prefetched: IntCounter,
pub(crate) parts_waited: IntCounter,
pub(crate) fast_path_eligible: IntCounter,
pub(crate) admin_count: IntCounter,
pub(crate) applied_exact_match: IntCounter,
pub(crate) applied_subset_match: IntCounter,
pub(crate) not_applied_too_many_updates: IntCounter,
pub(crate) batch: BatchWriteMetrics,
pub(crate) steps: CompactionStepTimings,
pub(crate) _steps_vec: CounterVec,
}
Fields§
§requested: IntCounter
§dropped: IntCounter
§skipped: IntCounter
§started: IntCounter
§applied: IntCounter
§timed_out: IntCounter
§failed: IntCounter
§noop: IntCounter
§seconds: Counter
§concurrency_waits: IntCounter
§queued_seconds: Counter
§memory_violations: IntCounter
§runs_compacted: IntCounter
§chunks_compacted: IntCounter
§not_all_prefetched: IntCounter
§parts_prefetched: IntCounter
§parts_waited: IntCounter
§fast_path_eligible: IntCounter
§admin_count: IntCounter
§applied_exact_match: IntCounter
§applied_subset_match: IntCounter
§not_applied_too_many_updates: IntCounter
§batch: BatchWriteMetrics
§steps: CompactionStepTimings
§_steps_vec: CounterVec
Implementations§
source§impl CompactionMetrics
impl CompactionMetrics
fn new(registry: &MetricsRegistry) -> Self
Trait Implementations§
Auto Trait Implementations§
impl Freeze for CompactionMetrics
impl !RefUnwindSafe for CompactionMetrics
impl Send for CompactionMetrics
impl Sync for CompactionMetrics
impl Unpin for CompactionMetrics
impl !UnwindSafe for CompactionMetrics
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
.