Struct mz_persist_client::metrics::SinkMetrics
source · pub struct SinkMetrics {
pub forwarded_batches: Counter,
pub forwarded_updates: Counter,
correction_insertions_total: IntCounter,
correction_deletions_total: IntCounter,
correction_capacity_increases_total: IntCounter,
correction_capacity_decreases_total: IntCounter,
correction_max_per_sink_worker_len_updates: UIntGaugeVec,
correction_max_per_sink_worker_capacity_updates: UIntGaugeVec,
}
Expand description
Metrics for the persist sink. (While this lies slightly outside the usual abstraction boundary of the client, it’s convenient to manage them together.
Fields§
§forwarded_batches: Counter
Number of small batches that were forwarded to the central append operator
forwarded_updates: Counter
Number of updates that were forwarded to the centralized append operator
correction_insertions_total: IntCounter
Cumulative record insertions made to the correction buffer across workers
correction_deletions_total: IntCounter
Cumulative record deletions made to the correction buffer across workers
correction_capacity_increases_total: IntCounter
Cumulative capacity increases made to the correction buffer across workers
correction_capacity_decreases_total: IntCounter
Cumulative capacity decreases made to the correction buffer across workers
correction_max_per_sink_worker_len_updates: UIntGaugeVec
Maximum length observed for any one correction buffer per worker
correction_max_per_sink_worker_capacity_updates: UIntGaugeVec
Maximum capacity observed for any one correction buffer per worker
Implementations§
source§impl SinkMetrics
impl SinkMetrics
fn new(registry: &MetricsRegistry) -> Self
sourcepub fn for_worker(&self, worker_id: usize) -> SinkWorkerMetrics
pub fn for_worker(&self, worker_id: usize) -> SinkWorkerMetrics
Obtains a SinkWorkerMetrics
instance, which allows for metric reporting
from a specific persist_sink
instance for a given worker. The reports will
update metrics shared across workers, but provide per-worker contributions
to them.
sourcepub fn report_correction_update_deltas(
&self,
correction_len_delta: UpdateDelta,
correction_cap_delta: UpdateDelta,
)
pub fn report_correction_update_deltas( &self, correction_len_delta: UpdateDelta, correction_cap_delta: UpdateDelta, )
Reports updates to the length and capacity of the correction buffer in the
write_batches
operator of a persist_sink
.
This method updates monotonic metrics based on the deltas and thus can be
called across workers and instances of persist_sink
.
Trait Implementations§
source§impl Clone for SinkMetrics
impl Clone for SinkMetrics
source§fn clone(&self) -> SinkMetrics
fn clone(&self) -> SinkMetrics
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl Freeze for SinkMetrics
impl !RefUnwindSafe for SinkMetrics
impl Send for SinkMetrics
impl Sync for SinkMetrics
impl Unpin for SinkMetrics
impl !UnwindSafe for SinkMetrics
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
std::ops::AddAssign
, for types that do not implement AddAssign
.