pub struct Metrics {Show 28 fields
pub(crate) stream_count: UIntGauge,
pub(crate) meta_size_bytes: UIntGauge,
pub(crate) unsealed_blob_count: UIntGauge,
pub(crate) unsealed_blob_bytes: UIntGauge,
pub(crate) trace_blob_count: UIntGauge,
pub(crate) trace_blob_bytes: UIntGauge,
pub(crate) cmd_queue_in: IntCounter,
pub(crate) cmd_run_count: IntCounter,
pub(crate) cmd_run_seconds: Counter,
pub(crate) cmd_failed_count: IntCounter,
pub(crate) cmd_step_seconds: Counter,
pub(crate) cmd_step_error_count: IntCounter,
pub(crate) compaction_count: IntCounter,
pub(crate) compaction_seconds: Counter,
pub(crate) compaction_write_bytes: IntCounter,
pub(crate) trace_compaction_error_response_count: IntCounter,
pub(crate) trace_compaction_skipped_count: IntCounter,
pub(crate) cmd_write_count: IntCounter,
pub(crate) cmd_write_record_count: IntCounter,
pub(crate) cmd_write_record_bytes: IntCounter,
pub(crate) unsealed: BlobMetricsByType,
pub(crate) trace: BlobMetricsByType,
pub(crate) meta: BlobMetricsByType,
pub(crate) blob_write_error_quota_count: IntCounter,
pub(crate) blob_write_error_other_count: IntCounter,
pub(crate) blob_read_cache_hit_count: IntCounter,
pub(crate) blob_read_cache_miss_count: IntCounter,
pub(crate) blob_read_cache_fetch_bytes: IntCounter,
}
Expand description
Persistence related monitoring metrics.
Intentionally not Clone because we expect this to be passed around in an Arc.
Fields
stream_count: UIntGauge
meta_size_bytes: UIntGauge
unsealed_blob_count: UIntGauge
unsealed_blob_bytes: UIntGauge
trace_blob_count: UIntGauge
trace_blob_bytes: UIntGauge
cmd_queue_in: IntCounter
cmd_run_count: IntCounter
cmd_run_seconds: Counter
cmd_failed_count: IntCounter
cmd_step_seconds: Counter
cmd_step_error_count: IntCounter
compaction_count: IntCounter
compaction_seconds: Counter
compaction_write_bytes: IntCounter
trace_compaction_error_response_count: IntCounter
trace_compaction_skipped_count: IntCounter
cmd_write_count: IntCounter
cmd_write_record_count: IntCounter
cmd_write_record_bytes: IntCounter
unsealed: BlobMetricsByType
trace: BlobMetricsByType
meta: BlobMetricsByType
blob_write_error_quota_count: IntCounter
blob_write_error_other_count: IntCounter
blob_read_cache_hit_count: IntCounter
blob_read_cache_miss_count: IntCounter
blob_read_cache_fetch_bytes: IntCounter
Implementations
sourceimpl Metrics
impl Metrics
sourcepub fn register_with(registry: &MetricsRegistry) -> Self
pub fn register_with(registry: &MetricsRegistry) -> Self
Returns a new Metrics instance connected to the given registry.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Metrics
impl Send for Metrics
impl Sync for Metrics
impl Unpin for Metrics
impl UnwindSafe for Metrics
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more