Struct DfeMetrics 

pub struct DfeMetrics { /* private fields */ }

Standard DFE metric set.

Provides labelled counters, gauges, and histograms covering transport, pipeline, records, scaling, spool, and security concerns.

Construct via DfeMetrics::register — this describes all metrics with the global recorder AND pushes descriptors into the manifest registry.

Implementations

impl DfeMetrics

pub fn register(manager: &MetricsManager) -> Self

Register all DFE metric descriptions with the global recorder and manifest registry.

Call this once after creating a MetricsManager. The returned handle is cheaply clonable (it’s zero-sized — all recording goes through the global metrics! macros).

Breaking change (v1.22): Now takes &MetricsManager to ensure platform metrics are tightly coupled with the manifest registry.

pub fn transport_sent(&self, transport: &str, count: u64)

Record messages successfully sent to a transport.

pub fn transport_send_errors(&self, transport: &str, count: u64)

Record send errors for a transport.

pub fn transport_backpressured(&self, transport: &str, count: u64)

Record backpressure events for a transport.

pub fn transport_refused(&self, transport: &str, count: u64)

Record refused messages for a transport.

pub fn transport_healthy(&self, transport: &str, healthy: bool)

Set transport health status.

pub fn transport_queue_size(&self, transport: &str, size: f64)

Set current transport queue size.

pub fn transport_queue_capacity(&self, transport: &str, capacity: f64)

Set transport queue capacity.

pub fn transport_inflight(&self, transport: &str, count: f64)

Set in-flight message count for a transport.

pub fn transport_send_duration(&self, transport: &str, seconds: f64)

Record batch send duration for a transport.

pub fn pipeline_ready(&self, ready: bool)

Set pipeline readiness state.

pub fn pipeline_stall(&self, seconds: u64)

Add stall duration to the cumulative stall counter (whole seconds).

pub fn records_received(&self, count: u64)

Record incoming records.

pub fn records_delivered(&self, count: u64)

Record successfully delivered records.

pub fn records_filtered(&self, count: u64)

Record filtered/dropped records.

pub fn records_dlq(&self, count: u64)

Record records sent to dead letter queue.

pub fn scaling_pressure(&self, pressure: f64)

Set normalised scaling pressure (0-100).

pub fn scaling_circuit_open(&self, open: bool)

Set circuit breaker state.

pub fn scaling_memory_pressure(&self, ratio: f64)

Set memory pressure ratio (0.0-1.0).

pub fn spool_bytes(&self, bytes: f64)

Set current spool size in bytes.

pub fn spool_messages(&self, count: f64)

Set current spool message count.

pub fn spool_disk_available(&self, bytes: f64)

Set available disk space for spool.

pub fn auth_failure(&self, reason: &str)

Record authentication failure.

pub fn validation_failure(&self, reason: &str)

Record validation failure.