Struct WorkerMetrics

pub struct WorkerMetrics {
    worker_label: String,
    metrics: ComputeMetrics,
    pub(crate) arrangement_maintenance_seconds_total: GenericCounter<AtomicF64>,
    pub(crate) arrangement_maintenance_active_info: UIntGauge,
    pub(crate) timely_step_duration_seconds: Histogram,
    pub(crate) persist_peek_seconds: Histogram,
    pub(crate) stashed_peek_seconds: Histogram,
    pub(crate) handle_command_duration_seconds: CommandMetrics<Histogram>,
    pub(crate) replica_expiration_timestamp_seconds: UIntGauge,
    pub(crate) replica_expiration_remaining_seconds: Gauge,
    shared_row_heap_capacity_bytes: UIntGauge,
}

Per-worker metrics.

Fields

worker_label: String

metrics: ComputeMetrics

arrangement_maintenance_seconds_total: GenericCounter<AtomicF64>

The amount of time spent in arrangement maintenance.

arrangement_maintenance_active_info: UIntGauge

1 if this worker is currently doing maintenance.

If maintenance turns out to take a very long time, this will allow us to gain a sense that Materialize is stuck on maintenance before the maintenance completes

timely_step_duration_seconds: Histogram

Histogram of Timely step timings.

persist_peek_seconds: Histogram

Histogram of persist peek durations.

stashed_peek_seconds: Histogram

Histogram of stashed peek durations.

handle_command_duration_seconds: CommandMetrics<Histogram>

Histogram of command handling durations.

replica_expiration_timestamp_seconds: UIntGauge

The timestamp of replica expiration.

replica_expiration_remaining_seconds: Gauge

Remaining seconds until replica expiration.

shared_row_heap_capacity_bytes: UIntGauge

Heap capacity of the shared row.

Implementations

impl WorkerMetrics

pub fn for_history(&self) -> HistoryMetrics<UIntGauge>

pub fn record_dataflow_reconciliation( &self, compatible: bool, uncompacted: bool, subscribe_free: bool, copy_to_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.

The properties are:

• compatible: The old and new dataflow descriptions are compatible.
• uncompacted: Collections currently installed for the dataflow exports have not been allowed to compact beyond that new dataflow as-of.
• subscribe_free: The dataflow does not export a subscribe sink.
• copy_to_free: The dataflow does not export a copy-to sink.
• dependencies_retained: All local inputs to the dataflow were retained by compute reconciliation.

pub fn record_shared_row_metrics(&self)

Record the heap capacity of the shared row.

fn inc_collection_count(&self, collection_type: &str, hydrated: bool)

Increase the count of maintained collections.

fn dec_collection_count(&self, collection_type: &str, hydrated: bool)

Decrease the count of maintained collections.

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

Sets the workload class for the compute metrics.

pub fn for_collection(&self, id: GlobalId) -> CollectionMetrics

Trait Implementations

impl Clone for WorkerMetrics

fn clone(&self) -> WorkerMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerMetrics

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

Formats the value using the given formatter.