emit_otlp 1.18.0

Emit diagnostic events to an OpenTelemetry-compatible collector.
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

use sval_derive::Value;

use crate::data::{AnyValue, KeyValue};

#[derive(Value)]
pub struct Metric<'a, N: ?Sized = str, U: ?Sized = str, D: ?Sized = MetricData<'a>> {
    #[sval(label = "name", index = 1)]
    pub name: &'a N,
    #[sval(label = "unit", index = 3)]
    pub unit: &'a U,
    #[sval(flatten)]
    pub data: &'a D,
}

#[derive(Value)]
pub enum MetricData<'a, DP: ?Sized = [NumberDataPoint<'a>]> {
    #[sval(label = "gauge", index = 5)]
    Gauge(Gauge<'a, DP>),
    #[sval(label = "sum", index = 7)]
    Sum(Sum<'a, DP>),
    #[sval(label = "exponentialHistogram", index = 10)]
    ExponentialHistogram(ExponentialHistogram<'a, DP>),
}

#[derive(Value)]
pub struct Gauge<'a, DP: ?Sized = [NumberDataPoint<'a>]> {
    #[sval(label = "dataPoints", index = 1)]
    pub data_points: &'a DP,
}

#[derive(Value)]
pub struct Sum<'a, DP: ?Sized = [NumberDataPoint<'a>]> {
    #[sval(label = "dataPoints", index = 1)]
    pub data_points: &'a DP,
    #[sval(label = "aggregationTemporality", index = 2)]
    pub aggregation_temporality: AggregationTemporality,
    #[sval(label = "isMonotonic", index = 3)]
    pub is_monotonic: bool,
}

#[derive(Value)]
pub struct ExponentialHistogram<'a, DP: ?Sized = [ExponentialHistogramDataPoint<'a>]> {
    #[sval(label = "dataPoints", index = 1)]
    pub data_points: &'a DP,
    #[sval(label = "aggregationTemporality", index = 2)]
    pub aggregation_temporality: AggregationTemporality,
}

#[derive(Value)]
#[repr(i32)]
#[sval(unlabeled_variants)]
pub enum AggregationTemporality {
    Unspecified = 0,
    Delta = 1,
    Cumulative = 2,
}

#[derive(Value)]
pub struct NumberDataPoint<'a, A: ?Sized = [KeyValue<&'a str, &'a AnyValue<'a>>]> {
    #[sval(label = "attributes", index = 7)]
    pub attributes: &'a A,
    #[sval(
        label = "startTimeUnixNano",
        index = 2,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub start_time_unix_nano: u64,
    #[sval(
        label = "timeUnixNano",
        index = 3,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub time_unix_nano: u64,
    #[sval(flatten)]
    pub value: NumberDataPointValue,
}

#[derive(Value)]
pub enum NumberDataPointValue {
    #[sval(label = "value", index = 4)]
    AsDouble(AsDouble),
    #[sval(label = "value", index = 6)]
    AsInt(AsInt),
}

#[derive(Value)]
pub struct AsDouble(pub f64);

#[derive(Value)]
#[sval(tag = "sval_protobuf::tags::PROTOBUF_I64")]
pub struct AsInt(pub i64);

#[derive(Value)]
pub struct ExponentialHistogramDataPoint<
    'a,
    A: ?Sized = [KeyValue<&'a str, &'a AnyValue<'a>>],
    P: ?Sized = [u64],
> {
    #[sval(label = "attributes", index = 1)]
    pub attributes: &'a A,
    #[sval(
        label = "startTimeUnixNano",
        index = 2,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub start_time_unix_nano: u64,
    #[sval(
        label = "timeUnixNano",
        index = 3,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub time_unix_nano: u64,
    #[sval(
        label = "count",
        index = 4,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub count: u64,
    #[sval(
        label = "scale",
        index = 6,
        data_tag = "sval_protobuf::tags::PROTOBUF_VARINT_SIGNED"
    )]
    pub scale: i32,
    #[sval(
        label = "zeroCount",
        index = 7,
        data_tag = "sval_protobuf::tags::PROTOBUF_I64"
    )]
    pub zero_count: u64,
    #[sval(label = "positive", index = 8)]
    pub positive: Option<Buckets<'a, P>>,
    #[sval(label = "negative", index = 9)]
    pub negative: Option<Buckets<'a, P>>,
}

#[derive(Value)]
pub struct Buckets<'a, P: ?Sized = [u64]> {
    #[sval(
        label = "offset",
        index = 1,
        data_tag = "sval_protobuf::tags::PROTOBUF_VARINT_SIGNED"
    )]
    pub offset: i32,
    #[sval(label = "bucketCounts", index = 2)]
    pub bucket_counts: &'a P,
}