Struct mz_persist_client::internal::metrics::ShardMetrics

source ·

pub struct ShardMetrics {Show 33 fields
    pub shard_id: ShardId,
    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>>,
    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>>>,
}

Fields§

§shard_id: ShardId§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>>§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>>>

Struct mz_persist_client::internal::metrics::ShardMetrics

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

Trait Implementations§

impl Debug for ShardMetrics

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

Auto Trait Implementations§

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