Struct mz_compute::metrics::ComputeMetrics

pub struct ComputeMetrics {

    workload_class: Arc<Mutex<Option<String>>>,
    history_command_count: UIntGaugeVec,
    history_dataflow_count: UIntGaugeVec,
    reconciliation_reused_dataflows_count_total: IntCounterVec,
    reconciliation_replaced_dataflows_count_total: IntCounterVec,
    arrangement_maintenance_seconds_total: CounterVec,
    arrangement_maintenance_active_info: UIntGaugeVec,
    pub(crate) timely_step_duration_seconds: Histogram,
    pub(crate) shared_row_heap_capacity_bytes: UIntGaugeVec,
    pub(crate) persist_peek_seconds: Histogram,
    pub(crate) handle_command_duration_seconds: HistogramVec,
    pub(crate) replica_expiration_timestamp_seconds: UIntGaugeVec,
    pub(crate) replica_expiration_remaining_seconds: GaugeVec,
}

Metrics exposed by compute replicas.

Fields

workload_class: Arc<Mutex<Option<String>>>

history_command_count: UIntGaugeVec

history_dataflow_count: UIntGaugeVec

reconciliation_reused_dataflows_count_total: IntCounterVec

reconciliation_replaced_dataflows_count_total: IntCounterVec

arrangement_maintenance_seconds_total: CounterVec

arrangement_maintenance_active_info: UIntGaugeVec

timely_step_duration_seconds: Histogram

shared_row_heap_capacity_bytes: UIntGaugeVec

Heap capacity of the shared row

persist_peek_seconds: Histogram

handle_command_duration_seconds: HistogramVec

Histogram of command handling durations.

replica_expiration_timestamp_seconds: UIntGaugeVec

The timestamp of replica expiration.

replica_expiration_remaining_seconds: GaugeVec

Remaining seconds until replica expiration.

Implementations

impl ComputeMetrics

pub fn register_with(registry: &MetricsRegistry) -> Self

pub fn for_history(&self, worker_id: usize) -> HistoryMetrics<UIntGauge>

pub fn for_traces(&self, worker_id: usize) -> TraceMetrics

pub fn record_dataflow_reconciliation( &self, worker_id: usize, compatible: bool, uncompacted: bool, subscribe_free: bool, dependencies_retained: bool, )

Record the reconciliation result for a single dataflow.

Reconciliation is recorded as successful if the given properties all hold. Otherwise it is recorded as unsuccessful, with a reason based on the first property that does not hold.

pub fn record_shared_row_metrics(&self, worker_id: usize)

Record the heap capacity of the shared row.

pub fn set_workload_class(&self, workload_class: Option<String>)

Sets the workload class for the compute metrics.

Trait Implementations

impl Clone for ComputeMetrics

fn clone(&self) -> ComputeMetrics

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ComputeMetrics

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

Formats the value using the given formatter.