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

/*!
Generated by the `emit_otlp_gen` crate.

These types are used to test `emit_otlp`. They're not part of regular builds.
*/

#![allow(dead_code)]

#[path = ""]
pub(crate) mod google {
    #[path = "./generated/google.rpc.rs"]
    pub(crate) mod rpc;
}

#[path = ""]
pub(crate) mod logs {
    #[path = "./generated/opentelemetry.proto.logs.v1.rs"]
    pub(crate) mod v1;
}

#[path = ""]
pub(crate) mod trace {
    #[path = "./generated/opentelemetry.proto.trace.v1.rs"]
    pub(crate) mod v1;
}

#[path = ""]
pub(crate) mod metrics {
    #[path = "./generated/opentelemetry.proto.metrics.v1.rs"]
    pub(crate) mod v1;
}

#[path = ""]
pub(crate) mod common {
    #[path = "./generated/opentelemetry.proto.common.v1.rs"]
    pub(crate) mod v1;
}

#[path = ""]
pub(crate) mod resource {
    #[path = "./generated/opentelemetry.proto.resource.v1.rs"]
    pub(crate) mod v1;
}

#[path = ""]
pub(crate) mod collector {
    #[path = ""]
    pub(crate) mod logs {
        #[path = "./generated/opentelemetry.proto.collector.logs.v1.rs"]
        pub(crate) mod v1;
    }

    #[path = ""]
    pub(crate) mod trace {
        #[path = "./generated/opentelemetry.proto.collector.trace.v1.rs"]
        pub(crate) mod v1;
    }

    #[path = ""]
    pub(crate) mod metrics {
        #[path = "./generated/opentelemetry.proto.collector.metrics.v1.rs"]
        pub(crate) mod v1;
    }
}

#[cfg(test)]
pub(crate) mod util {
    use super::*;

    pub(crate) fn string_value(v: impl Into<String>) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::StringValue(v.into())),
        }
    }

    pub(crate) fn bool_value(v: impl Into<bool>) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::BoolValue(v.into())),
        }
    }

    pub(crate) fn int_value(v: impl Into<i64>) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::IntValue(v.into())),
        }
    }

    pub(crate) fn double_value(v: impl Into<f64>) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::DoubleValue(v.into())),
        }
    }

    pub(crate) fn bytes_value(v: impl Into<Vec<u8>>) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::BytesValue(v.into())),
        }
    }

    pub(crate) fn array_value(
        v: impl IntoIterator<Item = common::v1::AnyValue>,
    ) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::ArrayValue(
                common::v1::ArrayValue {
                    values: v.into_iter().collect(),
                },
            )),
        }
    }

    pub(crate) fn kvlist_value(
        v: impl IntoIterator<Item = (String, common::v1::AnyValue)>,
    ) -> common::v1::AnyValue {
        common::v1::AnyValue {
            value: Some(common::v1::any_value::Value::KvlistValue(
                common::v1::KeyValueList {
                    values: v
                        .into_iter()
                        .map(|(key, value)| common::v1::KeyValue {
                            key,
                            value: Some(value),
                        })
                        .collect(),
                },
            )),
        }
    }
}