Type Alias mz_storage::statistics::SinkStatistics

pub type SinkStatistics = StorageStatistics<SinkStatisticsRecord, SinkStatisticsMetrics, ()>;

Statistics maintained for sinks.

Aliased Type

struct SinkStatistics { /* private fields */ }

Implementations

impl SinkStatistics

pub fn clear(&self)

Clear the data, resetting gauges to uninitialized. This does not reset prometheus gauges, which will be overwritten with new values.

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.

pub fn inc_messages_staged_by(&self, value: u64)

Increment the messages_staged stat.

pub fn inc_bytes_staged_by(&self, value: u64)

Increment the bytes_received stat.

pub fn inc_messages_committed_by(&self, value: u64)

Increment the messages_committed stat.

pub fn inc_bytes_committed_by(&self, value: u64)

Increment the bytes_committed stat.