Struct dataflow::server::metrics::WorkerMetrics

pub(super) struct WorkerMetrics {
    command_queue: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>,
    pending_peeks: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>,
    commands_processed: CommandsProcessedMetrics,
}

Prometheus metrics that we would like to easily export

Fields

command_queue: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>

The size of the command queue

Updated every time we decide to handle some

pending_peeks: DeleteOnDropGauge<'static, AtomicI64, Vec<String>>

The number of pending peeks

Updated every time we successfully fulfill a peek

commands_processed: CommandsProcessedMetrics

Total number of commands of each type processed

Implementations

impl WorkerMetrics

pub(super) fn observe_command_queue(&self, commands: &[Command])

pub(super) fn observe_pending_peeks(&self, pending_peeks: &[PendingPeek])

pub(super) fn observe_command(&mut self, command: &Command)

Observe that we have executed a command. Must be paired with WorkerMetrics::observe_command_finish

pub(super) fn observe_command_finish(&mut self)

Observe that we have executed a command