rustfs-kafka-async 1.2.0

Async Kafka client built on tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! Internal metrics definitions for rustfs-kafka-async.
//!
//! This module is only available when the `metrics` feature is enabled.

#[cfg(feature = "metrics")]
use metrics::{counter, gauge};

/// Records native consumer errors on the key observability dimensions.
pub fn record_native_consumer_error(
    phase: &str,
    class: &str,
    kafka_code: Option<&str>,
    recent_errors_len: usize,
    last_error_timestamp_ms: u128,
) {
    #[cfg(feature = "metrics")]
    {
        counter!("kafka.async.consumer.native.errors_total").increment(1);
        counter!(
            "kafka.async.consumer.native.errors_by_phase_total",
            "phase" => phase.to_owned()
        )
        .increment(1);
        counter!(
            "kafka.async.consumer.native.errors_by_class_total",
            "class" => class.to_owned()
        )
        .increment(1);
        if let Some(code) = kafka_code {
            counter!(
                "kafka.async.consumer.native.errors_by_kafka_code_total",
                "kafka_code" => code.to_owned()
            )
            .increment(1);
        }
        gauge!("kafka.async.consumer.native.recent_errors").set(recent_errors_len as f64);
        gauge!("kafka.async.consumer.native.last_error_timestamp_ms")
            .set(last_error_timestamp_ms as f64);
    }

    #[cfg(not(feature = "metrics"))]
    {
        let _ = phase;
        let _ = class;
        let _ = kafka_code;
        let _ = recent_errors_len;
        let _ = last_error_timestamp_ms;
    }
}