Struct mz_persist_client::internal::metrics::MetricsVecs

source ·

struct MetricsVecs {Show 32 fields
    cmd_started: IntCounterVec,
    cmd_cas_mismatch: IntCounterVec,
    cmd_succeeded: IntCounterVec,
    cmd_failed: IntCounterVec,
    cmd_seconds: CounterVec,
    external_op_started: IntCounterVec,
    external_op_succeeded: IntCounterVec,
    external_op_failed: IntCounterVec,
    external_op_bytes: IntCounterVec,
    external_op_seconds: CounterVec,
    external_consensus_truncated_count: IntCounter,
    external_blob_delete_noop_count: IntCounter,
    external_blob_sizes: Histogram,
    external_rtt_latency: GaugeVec,
    external_op_latency: HistogramVec,
    retry_started: IntCounterVec,
    retry_finished: IntCounterVec,
    retry_retries: IntCounterVec,
    retry_sleep_seconds: CounterVec,
    encode_count: IntCounterVec,
    encode_seconds: CounterVec,
    decode_count: IntCounterVec,
    decode_seconds: CounterVec,
    read_part_bytes: IntCounterVec,
    read_part_goodbytes: IntCounterVec,
    read_part_count: IntCounterVec,
    read_part_seconds: CounterVec,
    read_ts_rewrite: IntCounterVec,
    lock_acquire_count: IntCounterVec,
    lock_blocking_acquire_count: IntCounterVec,
    lock_blocking_seconds: CounterVec,
    alerts_metrics: Arc<AlertsMetrics>,
}

Fields§

§cmd_started: IntCounterVec§cmd_cas_mismatch: IntCounterVec§cmd_succeeded: IntCounterVec§cmd_failed: IntCounterVec§cmd_seconds: CounterVec§external_op_started: IntCounterVec§external_op_succeeded: IntCounterVec§external_op_failed: IntCounterVec§external_op_bytes: IntCounterVec§external_op_seconds: CounterVec§external_consensus_truncated_count: IntCounter§external_blob_delete_noop_count: IntCounter§external_blob_sizes: Histogram§external_rtt_latency: GaugeVec§external_op_latency: HistogramVec§retry_started: IntCounterVec§retry_finished: IntCounterVec§retry_retries: IntCounterVec§retry_sleep_seconds: CounterVec§encode_count: IntCounterVec§encode_seconds: CounterVec§decode_count: IntCounterVec§decode_seconds: CounterVec§read_part_bytes: IntCounterVec§read_part_goodbytes: IntCounterVec§read_part_count: IntCounterVec§read_part_seconds: CounterVec§read_ts_rewrite: IntCounterVec§lock_acquire_count: IntCounterVec§lock_blocking_acquire_count: IntCounterVec§lock_blocking_seconds: CounterVec§alerts_metrics: Arc<AlertsMetrics>

A minimal set of metrics imported into honeycomb for alerting.

Struct mz_persist_client::internal::metrics::MetricsVecsCopy item path

Fields§

Implementations§

impl MetricsVecs

fn new(registry: &MetricsRegistry) -> Self

fn cmds_metrics(&self, registry: &MetricsRegistry) -> CmdsMetrics

fn cmd_metrics(&self, cmd: &str) -> CmdMetrics

fn retries_metrics(&self) -> RetriesMetrics

fn retry_metrics(&self, name: &str) -> RetryMetrics

fn codecs_metrics(&self) -> CodecsMetrics

fn codec_metrics(&self, op: &str) -> CodecMetrics

fn blob_metrics(&self) -> BlobMetrics

fn consensus_metrics(&self) -> ConsensusMetrics

fn external_op_metrics( &self, op: &str, latency_histogram: bool, ) -> ExternalOpMetrics

fn batch_part_read_metrics(&self) -> BatchPartReadMetrics

fn read_metrics(&self, op: &str) -> ReadMetrics

fn locks_metrics(&self) -> LocksMetrics

fn lock_metrics(&self, op: &str) -> LockMetrics

Trait Implementations§

impl Debug for MetricsVecs

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

Auto Trait Implementations§

impl Freeze for MetricsVecs

impl !RefUnwindSafe for MetricsVecs

impl Send for MetricsVecs

impl Sync for MetricsVecs

impl Unpin for MetricsVecs

impl !UnwindSafe for MetricsVecs

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<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<T> Same for T

type Output = T

impl<'a, S, T> Semigroup<&'a S> for Twhere T: Semigroup<S>,

fn plus_equals(&mut self, rhs: &&'a S)

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::internal::metrics::MetricsVecs

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<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<'a, S, T> Semigroup<&'a S> for T
where T: Semigroup<S>,

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>,