Module dfe_groups 

Available on crate feature metrics-dfe and (crate features metrics or otel-metrics) only.

Composable DFE metric groups.

Opt-in metric structs for DFE pipeline applications. Each group registers standardised metrics using the MetricsManager namespace prefix (e.g. dfe_loader_buffer_bytes).

Feature-gated behind metrics-dfe. Non-DFE apps are unaffected.

Usage

use hyperi_rustlib::metrics::MetricsManager;
use hyperi_rustlib::metrics::dfe_groups::*;

let mgr = MetricsManager::new("dfe_loader");
let app = AppMetrics::new(&mgr, env!("CARGO_PKG_VERSION"), "abc123");
let buffer = BufferMetrics::new(&mgr);
let consumer = ConsumerMetrics::new(&mgr);
let sink = SinkMetrics::new(&mgr);
let cb = CircuitBreakerMetrics::new(&mgr);
let bp = BackpressureMetrics::new(&mgr);

app.record_received(100);
buffer.record_flush(0.042, "size");
consumer.set_lag("events", 3, 1500);
sink.record_duration("clickhouse", 0.015);
cb.record_transition("db.events", "open");
bp.record_event();

Structs

AppMetrics

Mandatory metrics for every DFE application.

BackpressureMetrics

Backpressure event tracking.

BufferMetrics

Buffer metrics for DFE apps with batching.

CircuitBreakerMetrics

Circuit breaker metrics for per-target failure tracking.

ConsumerMetrics

Kafka consumer metrics.

EnrichmentMetrics

Enrichment cache metrics.

SchemaCacheMetrics

Schema cache metrics.

SinkMetrics

Sink write metrics.