Struct InMemoryWorkflowMetrics 

pub struct InMemoryWorkflowMetrics { /* private fields */ }

In-memory adapter useful for tests and lightweight local diagnostics.

Implementations

impl InMemoryWorkflowMetrics

pub fn snapshot(&self) -> InMemoryMetricsSnapshot

Trait Implementations

impl Clone for InMemoryWorkflowMetrics

fn clone(&self) -> InMemoryWorkflowMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryWorkflowMetrics

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

Formats the value using the given formatter.

impl Default for InMemoryWorkflowMetrics

fn default() -> InMemoryWorkflowMetrics

Returns the “default value” for a type.

impl WorkflowMetrics for InMemoryWorkflowMetrics

fn observe_node_latency( &self, workflow_name: &str, node_id: &str, latency: Duration, )

fn increment_node_success(&self, workflow_name: &str, node_id: &str)

fn increment_node_failure(&self, workflow_name: &str, node_id: &str)

fn set_queue_depth(&self, queue_name: &str, depth: u64)

fn set_worker_health(&self, worker_id: &str, health: WorkerHealthState)