Struct mz_persist_client::internal::metrics::ShardMetrics

source ·

pub struct ShardMetrics {Show 45 fields
    pub shard_id: ShardId,
    pub name: String,
    pub since: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>,
    pub upper: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>,
    pub largest_batch_size: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub latest_rollup_size: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub encoded_diff_size: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub hollow_batch_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub spine_batch_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub batch_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    batch_part_version_count: UIntGaugeVec,
    batch_part_version_bytes: UIntGaugeVec,
    batch_part_version_map: Mutex<BTreeMap<String, BatchPartVersionMetrics>>,
    pub update_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub rollup_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub seqnos_held: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub seqnos_since_last_rollup: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub gc_seqno_held_parts: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub gc_live_diffs: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub usage_current_state_batches_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub usage_current_state_rollups_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub usage_referenced_not_current_state_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub usage_not_leaked_not_referenced_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub usage_leaked_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub gc_finished: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub compaction_applied: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub cmd_succeeded: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub pubsub_push_diff_applied: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub pubsub_push_diff_not_applied_stale: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub pubsub_push_diff_not_applied_out_of_order: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub blob_gets: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub blob_sets: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub live_writers: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub unconsolidated_snapshot: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    pub backpressure_emitted_bytes: Arc<DeleteOnDropCounter<'static, AtomicU64, Vec<String>>>,
    pub backpressure_last_backpressured_bytes: Arc<DeleteOnDropGauge<'static, AtomicU64, Vec<String>>>,
    pub backpressure_retired_bytes: Arc<DeleteOnDropCounter<'static, AtomicU64, Vec<String>>>,
    pub rewrite_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub inline_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub inline_part_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub compact_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub compacting_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub noncompact_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub schema_registry_version_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
    pub inline_backpressure_count: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
}

Fields§

§shard_id: ShardId§name: String§since: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>§upper: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>§largest_batch_size: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§latest_rollup_size: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§encoded_diff_size: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§hollow_batch_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§spine_batch_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§batch_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§batch_part_version_count: UIntGaugeVec§batch_part_version_bytes: UIntGaugeVec§batch_part_version_map: Mutex<BTreeMap<String, BatchPartVersionMetrics>>§update_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§rollup_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§seqnos_held: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§seqnos_since_last_rollup: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§gc_seqno_held_parts: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§gc_live_diffs: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§usage_current_state_batches_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§usage_current_state_rollups_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§usage_referenced_not_current_state_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§usage_not_leaked_not_referenced_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§usage_leaked_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§gc_finished: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§compaction_applied: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§cmd_succeeded: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§pubsub_push_diff_applied: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§pubsub_push_diff_not_applied_stale: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§pubsub_push_diff_not_applied_out_of_order: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§blob_gets: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§blob_sets: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§live_writers: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§unconsolidated_snapshot: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>§backpressure_emitted_bytes: Arc<DeleteOnDropCounter<'static, AtomicU64, Vec<String>>>§backpressure_last_backpressured_bytes: Arc<DeleteOnDropGauge<'static, AtomicU64, Vec<String>>>§backpressure_retired_bytes: Arc<DeleteOnDropCounter<'static, AtomicU64, Vec<String>>>§rewrite_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§inline_part_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§inline_part_bytes: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§compact_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§compacting_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§noncompact_batches: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§schema_registry_version_count: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>§inline_backpressure_count: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>

Struct mz_persist_client::internal::metrics::ShardMetricsCopy item path

Fields§

Implementations§

impl ShardMetrics

pub fn new( shard_id: &ShardId, name: &str, shards_metrics: &ShardsMetrics, ) -> Self

pub fn set_since<T: Codec64>(&self, since: &Antichain<T>)

pub fn set_upper<T: Codec64>(&self, upper: &Antichain<T>)

pub(crate) fn set_batch_part_versions<'a>( &self, batch_parts_by_version: impl Iterator<Item = (&'a str, usize)>, )

Trait Implementations§

impl Debug for ShardMetrics

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

Auto Trait Implementations§

impl !Freeze for ShardMetrics

impl !RefUnwindSafe for ShardMetrics

impl Send for ShardMetrics

impl Sync for ShardMetrics

impl Unpin for ShardMetrics

impl !UnwindSafe for ShardMetrics

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::ShardMetrics

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