Type Alias mz_storage::statistics::SinkStatistics
source · pub type SinkStatistics = StorageStatistics<SinkStatisticsRecord, SinkStatisticsMetrics, ()>;
Expand description
Statistics maintained for sinks.
Aliased Type§
struct SinkStatistics { /* private fields */ }
Implementations§
source§impl SinkStatistics
impl SinkStatistics
sourcepub fn clear(&self)
pub fn clear(&self)
Clear the data, resetting gauges to uninitialized. This does not reset prometheus gauges, which will be overwritten with new values.
sourcepub fn snapshot(&mut self) -> Option<SinkStatisticsRecord>
pub fn snapshot(&mut self) -> Option<SinkStatisticsRecord>
Get a snapshot of the data, returning None
if all gauges are not initialized.
This also resets counters, so that we continue to move diffs around.
sourcepub fn inc_messages_staged_by(&self, value: u64)
pub fn inc_messages_staged_by(&self, value: u64)
Increment the messages_staged
stat.
sourcepub fn inc_bytes_staged_by(&self, value: u64)
pub fn inc_bytes_staged_by(&self, value: u64)
Increment the bytes_received
stat.
sourcepub fn inc_messages_committed_by(&self, value: u64)
pub fn inc_messages_committed_by(&self, value: u64)
Increment the messages_committed
stat.
sourcepub fn inc_bytes_committed_by(&self, value: u64)
pub fn inc_bytes_committed_by(&self, value: u64)
Increment the bytes_committed
stat.