Struct Metrics 

pub struct Metrics { /* private fields */ }

Cloneable server metrics handle backed by a prometheus registry.

Implementations

impl Metrics

pub fn new() -> Result<Self, MetricsError>

Construct the server metrics registry and register all exported metrics.

Errors

Returns MetricsError::Register if prometheus rejects a metric descriptor.

pub fn encode(&self) -> Result<Vec<u8>, MetricsError>

Encode all currently gathered metrics in prometheus text exposition format.

Errors

Returns MetricsError::Encode if prometheus cannot encode gathered metrics.

pub fn workflow_started(&self, namespace: &str, workflow_type: &str)

Increment the workflow-start counter.

pub fn workflow_completed(&self, namespace: &str, status: &str)

Increment the workflow-terminal counter.

pub fn workflow_reopened(&self, namespace: &str)

Increment the workflow-reopen counter when a failed run is reopened.

pub fn activity_dispatched(&self, namespace: &str, activity_type: &str)

Increment the activity-dispatch counter and in-flight gauge.

pub fn activity_completed( &self, namespace: &str, activity_type: &str, outcome: &str, duration: Duration, )

Increment the activity-completion counter, observe duration, and decrement in-flight gauge.

pub fn activity_abandoned(&self, namespace: &str)

Decrement in-flight activity gauge when dispatch fails before a result can arrive.

pub fn store_operation(&self, operation: &str, duration: Duration)

Observe a store operation duration.

pub fn activity_lease_record_failed(&self)

An activity lease this install knew and failed to record.

pub fn worker_connected(&self, namespace: &str)

Increment connected worker gauge for a namespace.

pub fn worker_disconnected(&self, namespace: &str)

Decrement connected worker gauge for a namespace.

pub fn signal_delivered(&self, namespace: &str, residency: &str)

Increment signal delivery counter.

pub fn schedule_fired(&self, namespace: &str)

Increment schedule-fired counter.

pub fn deploy_operation(&self, operation: &str, outcome: &str)

Increment the deploy-operation counter for one mutation outcome.

pub fn deploy_denied(&self, transport: &str)

Increment the deploy-denied counter for a transport.

pub fn set_loaded_workflow_versions(&self, workflow_type: &str, count: i64)

Set the loaded-version gauge for one workflow type from the post-operation listing.

Trait Implementations

impl Clone for Metrics

fn clone(&self) -> Metrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Metrics

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

Formats the value using the given formatter.