Struct mz_persist_client::internal::metrics::TaskMetrics

pub struct TaskMetrics {
    f64_gauges: Vec<(Gauge, fn(_: &TaskMetrics) -> f64)>,
    u64_gauges: Vec<(GenericGauge<AtomicU64>, fn(_: &TaskMetrics) -> u64)>,
    monitor: TaskMonitor,
}

A standard set of metrics for an async task. Call TaskMetrics::instrument_task to instrument a future and report its metrics for this task type.

Fields

f64_gauges: Vec<(Gauge, fn(_: &TaskMetrics) -> f64)>

u64_gauges: Vec<(GenericGauge<AtomicU64>, fn(_: &TaskMetrics) -> u64)>

monitor: TaskMonitor

Implementations

impl TaskMetrics

pub fn new(name: &str) -> Self

pub fn instrument_task<F>(&self, task: F) -> Instrumented<F>

Instrument the provided future. The expectation is that the result will be executed as a task. (See TaskMonitor::instrument for more context.)

Trait Implementations

impl Clone for TaskMetrics

fn clone(&self) -> TaskMetrics

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Collector for TaskMetrics

fn desc(&self) -> Vec<&Desc>

Return descriptors for metrics.

fn collect(&self) -> Vec<MetricFamily>

Collect metrics.

impl Debug for TaskMetrics

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

Formats the value using the given formatter.