Struct mz_persist_client::Metrics
source · [−]pub struct Metrics {Show 14 fields
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 postgres_consensus: PostgresConsensusMetrics,
/* private fields */
}
Expand description
Prometheus monitoring metrics.
Intentionally not Clone because we expect this to be passed around in an Arc.
Fields
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
postgres_consensus: PostgresConsensusMetrics
Metrics for Postgres-backed consensus implementation
Implementations
sourceimpl Metrics
impl Metrics
sourcepub fn new(cfg: &PersistConfig, registry: &MetricsRegistry) -> Self
pub fn new(cfg: &PersistConfig, registry: &MetricsRegistry) -> Self
Returns a new Metrics instance connected to the given registry.
sourcepub fn write_amplification(&self) -> f64
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
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 Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
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>
T
in a tonic::Request
sourceimpl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.