Struct mz_persist_client::internal::metrics::Metrics

pub struct Metrics {Show 30 fields
    _vecs: MetricsVecs,
    _uptime: ComputedGauge,
    pub blob: BlobMetrics,
    pub consensus: ConsensusMetrics,
    pub cmds: CmdsMetrics,
    pub retries: RetriesMetrics,
    pub user: BatchWriteMetrics,
    pub read: BatchPartReadMetrics,
    pub compaction: CompactionMetrics,
    pub gc: GcMetrics,
    pub lease: LeaseMetrics,
    pub codecs: CodecsMetrics,
    pub state: StateMetrics,
    pub shards: ShardsMetrics,
    pub audit: UsageAuditMetrics,
    pub locks: LocksMetrics,
    pub watch: WatchMetrics,
    pub pubsub_client: PubSubClientMetrics,
    pub pushdown: PushdownMetrics,
    pub consolidation: ConsolidationMetrics,
    pub blob_cache_mem: BlobMemCache,
    pub tasks: TasksMetrics,
    pub columnar: ColumnarMetrics,
    pub schema: SchemaMetrics,
    pub inline: InlineMetrics,
    pub(crate) semaphore: SemaphoreMetrics,
    pub sink: SinkMetrics,
    pub s3_blob: S3BlobMetrics,
    pub postgres_consensus: PostgresClientMetrics,
    pub(crate) registry: MetricsRegistry,
}

Expand description

Prometheus monitoring metrics.

Intentionally not Clone because we expect this to be passed around in an Arc.

Fields§

§_vecs: MetricsVecs§_uptime: ComputedGauge§blob: BlobMetrics

Metrics for Blob usage.

§consensus: ConsensusMetrics

Metrics for Consensus usage.

§cmds: CmdsMetrics

Metrics of command evaluation.

§retries: RetriesMetrics

Metrics for each retry loop.

§user: BatchWriteMetrics

Metrics for batches written directly on behalf of a user (BatchBuilder or one of the sugar methods that use it).

§read: BatchPartReadMetrics

Metrics for reading batch parts

§compaction: CompactionMetrics

Metrics for compaction.

§gc: GcMetrics

Metrics for garbage collection.

§lease: LeaseMetrics

Metrics for leasing and automatic lease expiry.

§codecs: CodecsMetrics

Metrics for various encodings and decodings.

§state: StateMetrics

Metrics for (incremental) state updates and fetches.

§shards: ShardsMetrics

Metrics for various per-shard measurements.

§audit: UsageAuditMetrics

Metrics for auditing persist usage

§locks: LocksMetrics

Metrics for locking.

§watch: WatchMetrics

Metrics for StateWatch.

§pubsub_client: PubSubClientMetrics

Metrics for PubSub client.

§pushdown: PushdownMetrics

Metrics for mfp/filter pushdown.

§consolidation: ConsolidationMetrics

Metrics for consolidation.

§blob_cache_mem: BlobMemCache

Metrics for blob caching.

§tasks: TasksMetrics

Metrics for tokio tasks.

§columnar: ColumnarMetrics

Metrics for columnar data encoding and decoding.

§schema: SchemaMetrics

Metrics for schemas and the schema registry.

§inline: InlineMetrics

Metrics for inline writes.

§semaphore: SemaphoreMetrics

Semaphore to limit memory/disk use by fetches.

§sink: SinkMetrics

Metrics for the persist sink.

§s3_blob: S3BlobMetrics

Metrics for S3-backed blob implementation

§postgres_consensus: PostgresClientMetrics

Metrics for Postgres-backed consensus implementation

§registry: MetricsRegistry

Implementations§

impl Metrics

pub fn new(cfg: &PersistConfig, registry: &MetricsRegistry) -> Self

Returns a new Metrics instance connected to the given registry.

pub fn write_amplification(&self) -> f64

Returns the current lifetime write amplification reflected in these metrics.

Only exposed for tests, persistcli, and benchmarks.

Trait Implementations§

impl Debug for Metrics

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl !Freeze for Metrics

impl !RefUnwindSafe for Metrics

impl Send for Metrics

impl Sync for Metrics

impl Unpin for Metrics

impl !UnwindSafe for Metrics

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T, U> CastInto<U> for T
where U: CastFrom<T>,

fn cast_into(self) -> U

Performs the cast.

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.

impl<T> Pointable for T

const ALIGN: usize = _

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<P, R> ProtoType<R> for P
where R: RustType<P>,

fn into_rust(self) -> Result<R, TryFromProtoError>

See RustType::from_proto.

fn from_rust(rust: &R) -> P

See RustType::into_proto.

impl<T> Same for T

type Output = T

Should always be Self

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

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

The method of std::ops::AddAssign, for types that do not implement AddAssign.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where 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>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more