pub struct MetaMetrics {Show 76 fields
pub worker_num: IntGaugeVec,
pub meta_type: IntGaugeVec,
pub grpc_latency: HistogramVec,
pub barrier_latency: Histogram,
pub barrier_wait_commit_latency: Histogram,
pub barrier_send_latency: Histogram,
pub all_barrier_nums: IntGaugeVec,
pub in_flight_barrier_nums: IntGaugeVec,
pub last_committed_barrier_time: IntGauge,
pub snapshot_backfill_barrier_latency: LabelGuardedHistogramVec<2>,
pub snapshot_backfill_wait_commit_latency: LabelGuardedHistogramVec<1>,
pub snapshot_backfill_lag: LabelGuardedIntGaugeVec<1>,
pub snapshot_backfill_inflight_barrier_num: LabelGuardedIntGaugeVec<1>,
pub recovery_failure_cnt: IntCounter,
pub recovery_latency: Histogram,
pub max_committed_epoch: IntGauge,
pub safe_epoch: IntGauge,
pub min_pinned_epoch: IntGauge,
pub level_sst_num: IntGaugeVec,
pub level_compact_cnt: IntGaugeVec,
pub compact_frequency: IntCounterVec,
pub level_file_size: IntGaugeVec,
pub version_size: IntGauge,
pub current_version_id: IntGauge,
pub checkpoint_version_id: IntGauge,
pub min_pinned_version_id: IntGauge,
pub min_safepoint_version_id: IntGauge,
pub write_stop_compaction_groups: IntGaugeVec,
pub full_gc_trigger_count: IntGauge,
pub full_gc_candidate_object_count: Histogram,
pub full_gc_selected_object_count: Histogram,
pub version_stats: IntGaugeVec,
pub materialized_view_stats: IntGaugeVec,
pub stale_object_count: IntGauge,
pub stale_object_size: IntGauge,
pub old_version_object_count: IntGauge,
pub old_version_object_size: IntGauge,
pub time_travel_object_count: IntGauge,
pub current_version_object_count: IntGauge,
pub current_version_object_size: IntGauge,
pub total_object_count: IntGauge,
pub total_object_size: IntGauge,
pub delta_log_count: IntGauge,
pub version_checkpoint_latency: Histogram,
pub hummock_manager_lock_time: HistogramVec,
pub hummock_manager_real_process_time: HistogramVec,
pub compact_skip_frequency: IntCounterVec,
pub compact_pending_bytes: IntGaugeVec,
pub compact_level_compression_ratio: GenericGaugeVec<AtomicF64>,
pub level_compact_task_cnt: IntGaugeVec,
pub time_after_last_observation: Arc<AtomicU64>,
pub l0_compact_level_count: HistogramVec,
pub compact_task_size: HistogramVec,
pub compact_task_file_count: HistogramVec,
pub compact_task_batch_count: HistogramVec,
pub split_compaction_group_count: IntCounterVec,
pub state_table_count: IntGaugeVec,
pub branched_sst_count: IntGaugeVec,
pub compaction_event_consumed_latency: Histogram,
pub compaction_event_loop_iteration_latency: Histogram,
pub object_store_metric: Arc<ObjectStoreMetrics>,
pub source_is_up: LabelGuardedIntGaugeVec<2>,
pub source_enumerator_metrics: Arc<EnumeratorMetrics>,
pub actor_info: IntGaugeVec,
pub table_info: IntGaugeVec,
pub sink_info: IntGaugeVec,
pub table_write_throughput: IntCounterVec,
pub merge_compaction_group_count: IntCounterVec,
pub auto_schema_change_failure_cnt: LabelGuardedIntCounterVec<2>,
pub auto_schema_change_success_cnt: LabelGuardedIntCounterVec<2>,
pub auto_schema_change_latency: LabelGuardedHistogramVec<2>,
pub time_travel_version_replay_latency: Histogram,
pub compaction_group_count: IntGauge,
pub compaction_group_size: IntGaugeVec,
pub compaction_group_file_count: IntGaugeVec,
pub compaction_group_throughput: IntGaugeVec,
}
Fields§
§worker_num: IntGaugeVec
The number of workers in the cluster.
meta_type: IntGaugeVec
The roles of all meta nodes in the cluster.
grpc_latency: HistogramVec
gRPC latency of meta services
barrier_latency: Histogram
The duration from barrier injection to commit It is the sum of inflight-latency, sync-latency and wait-commit-latency
barrier_wait_commit_latency: Histogram
The duration from barrier complete to commit
barrier_send_latency: Histogram
Latency between each barrier send
all_barrier_nums: IntGaugeVec
The number of all barriers. It is the sum of barriers that are in-flight or completed but waiting for other barriers
in_flight_barrier_nums: IntGaugeVec
The number of in-flight barriers
last_committed_barrier_time: IntGauge
The timestamp (UNIX epoch seconds) of the last committed barrier’s epoch time.
snapshot_backfill_barrier_latency: LabelGuardedHistogramVec<2>
The barrier latency in second of table_id
and snapshto backfill barrier_type
snapshot_backfill_wait_commit_latency: LabelGuardedHistogramVec<1>
The latency of commit epoch of table_id
snapshot_backfill_lag: LabelGuardedIntGaugeVec<1>
The lags between the upstream epoch and the downstream epoch.
snapshot_backfill_inflight_barrier_num: LabelGuardedIntGaugeVec<1>
The number of inflight barriers of table_id
recovery_failure_cnt: IntCounter
§recovery_latency: Histogram
§max_committed_epoch: IntGauge
Max committed epoch
safe_epoch: IntGauge
The smallest epoch that has not been GCed
.
min_pinned_epoch: IntGauge
The smallest epoch that is being pinned.
level_sst_num: IntGaugeVec
The number of SSTs in each level
level_compact_cnt: IntGaugeVec
The number of SSTs to be merged to next level in each level
compact_frequency: IntCounterVec
The number of compact tasks
level_file_size: IntGaugeVec
Size of each level
version_size: IntGauge
Hummock version size
current_version_id: IntGauge
The version Id of current version.
checkpoint_version_id: IntGauge
The version id of checkpoint version.
min_pinned_version_id: IntGauge
The smallest version id that is being pinned by worker nodes.
min_safepoint_version_id: IntGauge
The smallest version id that is being guarded by meta node safe points.
write_stop_compaction_groups: IntGaugeVec
Compaction groups that is in write stop state.
full_gc_trigger_count: IntGauge
The number of attempts to trigger full GC.
full_gc_candidate_object_count: Histogram
The number of candidate object to delete after scanning object store.
full_gc_selected_object_count: Histogram
The number of object to delete after filtering by meta node.
version_stats: IntGaugeVec
Hummock version stats
materialized_view_stats: IntGaugeVec
Hummock version stats
stale_object_count: IntGauge
Total number of objects that is no longer referenced by versions.
stale_object_size: IntGauge
Total size of objects that is no longer referenced by versions.
old_version_object_count: IntGauge
Total number of objects that is still referenced by non-current versions.
old_version_object_size: IntGauge
Total size of objects that is still referenced by non-current versions.
time_travel_object_count: IntGauge
Total number of objects that is referenced by time travel.
current_version_object_count: IntGauge
Total number of objects that is referenced by current version.
current_version_object_size: IntGauge
Total size of objects that is referenced by current version.
total_object_count: IntGauge
Total number of objects that includes dangling objects.
total_object_size: IntGauge
Total size of objects that includes dangling objects.
delta_log_count: IntGauge
The number of hummock version delta log.
version_checkpoint_latency: Histogram
latency of version checkpoint
hummock_manager_lock_time: HistogramVec
Latency for hummock manager to acquire lock
hummock_manager_real_process_time: HistogramVec
Latency for hummock manager to really process a request after acquire the lock
compact_skip_frequency: IntCounterVec
The number of compactions from one level to another level that have been skipped
compact_pending_bytes: IntGaugeVec
Bytes of lsm tree needed to reach balance
compact_level_compression_ratio: GenericGaugeVec<AtomicF64>
Per level compression ratio
level_compact_task_cnt: IntGaugeVec
Per level number of running compaction task
time_after_last_observation: Arc<AtomicU64>
§l0_compact_level_count: HistogramVec
§compact_task_size: HistogramVec
§compact_task_file_count: HistogramVec
§compact_task_batch_count: HistogramVec
§split_compaction_group_count: IntCounterVec
§state_table_count: IntGaugeVec
§branched_sst_count: IntGaugeVec
§compaction_event_consumed_latency: Histogram
§compaction_event_loop_iteration_latency: Histogram
§object_store_metric: Arc<ObjectStoreMetrics>
§source_is_up: LabelGuardedIntGaugeVec<2>
supervisor for which source is still up.
source_enumerator_metrics: Arc<EnumeratorMetrics>
§actor_info: IntGaugeVec
A dummpy gauge metrics with its label to be the mapping from actor id to fragment id
table_info: IntGaugeVec
A dummpy gauge metrics with its label to be the mapping from table id to actor id
sink_info: IntGaugeVec
A dummy gauge metrics with its label to be the mapping from actor id to sink id
table_write_throughput: IntCounterVec
Write throughput of commit epoch for each stable
merge_compaction_group_count: IntCounterVec
The number of compaction groups that have been triggered to move
auto_schema_change_failure_cnt: LabelGuardedIntCounterVec<2>
§auto_schema_change_success_cnt: LabelGuardedIntCounterVec<2>
§auto_schema_change_latency: LabelGuardedHistogramVec<2>
§time_travel_version_replay_latency: Histogram
§compaction_group_count: IntGauge
§compaction_group_size: IntGaugeVec
§compaction_group_file_count: IntGaugeVec
§compaction_group_throughput: IntGaugeVec
Implementations§
source§impl MetaMetrics
impl MetaMetrics
Trait Implementations§
source§impl Clone for MetaMetrics
impl Clone for MetaMetrics
source§fn clone(&self) -> MetaMetrics
fn clone(&self) -> MetaMetrics
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl Freeze for MetaMetrics
impl !RefUnwindSafe for MetaMetrics
impl Send for MetaMetrics
impl Sync for MetaMetrics
impl Unpin for MetaMetrics
impl !UnwindSafe for MetaMetrics
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)§impl<T> Conv for T
impl<T> Conv for T
§impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§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>
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
§impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<Source> Sculptor<HNil, HNil> for Source
impl<Source> Sculptor<HNil, HNil> for Source
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.