Skip to content

Commit

Permalink
opentelemetry 0.26 (#116)
Browse files Browse the repository at this point in the history
  • Loading branch information
getong authored Oct 2, 2024
1 parent ad208a1 commit 7c131c4
Show file tree
Hide file tree
Showing 6 changed files with 23 additions and 31 deletions.
14 changes: 7 additions & 7 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,10 @@ resolver = "2"
debug = 1

[workspace.dependencies]
opentelemetry = "0.25"
opentelemetry-appender-tracing = "0.25"
opentelemetry-http = "0.25"
opentelemetry-proto = { version = "0.25", default-features = false }
opentelemetry_sdk = { version = "0.25", default-features = false }
opentelemetry-stdout = "0.25"
opentelemetry-semantic-conventions = "0.25"
opentelemetry = "0.26"
opentelemetry-appender-tracing = "0.26"
opentelemetry-http = "0.26"
opentelemetry-proto = { version = "0.26", default-features = false }
opentelemetry_sdk = { version = "0.26", default-features = false }
opentelemetry-stdout = "0.26"
opentelemetry-semantic-conventions = { version = "0.26", features = ["semconv_experimental"] }
2 changes: 1 addition & 1 deletion opentelemetry-etw-logs/src/logs/exporter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -283,7 +283,7 @@ impl ETWExporter {
event: &mut tld::EventBuilder,
log_record: &'a opentelemetry_sdk::logs::LogRecord,
field_tag: u32,
) -> (Option<i64>, Option<&str>) {
) -> (Option<i64>, Option<&'a str>) {
//populate CS PartC
let mut event_id: Option<i64> = None;
let mut event_name: Option<&str> = None;
Expand Down
18 changes: 9 additions & 9 deletions opentelemetry-resource-detectors/src/host.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,13 +30,13 @@ impl ResourceDetector for HostResourceDetector {
// Get host.id
(self.host_id_detect)().map(|host_id| {
KeyValue::new(
opentelemetry_semantic_conventions::resource::HOST_ID,
opentelemetry_semantic_conventions::attribute::HOST_ID,
host_id,
)
}),
// Get host.arch
Some(KeyValue::new(
opentelemetry_semantic_conventions::resource::HOST_ARCH,
opentelemetry_semantic_conventions::attribute::HOST_ARCH,
ARCH,
)),
]
Expand Down Expand Up @@ -99,12 +99,12 @@ mod tests {
assert_eq!(resource.len(), 2);
assert!(resource
.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ID
opentelemetry_semantic_conventions::attribute::HOST_ID
))
.is_some());
assert!(resource
.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ARCH
opentelemetry_semantic_conventions::attribute::HOST_ARCH
))
.is_some())
}
Expand All @@ -117,12 +117,12 @@ mod tests {
assert_eq!(resource.len(), 2);
assert!(resource
.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ID
opentelemetry_semantic_conventions::attribute::HOST_ID
))
.is_some());
assert!(resource
.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ARCH
opentelemetry_semantic_conventions::attribute::HOST_ARCH
))
.is_some())
}
Expand All @@ -133,22 +133,22 @@ mod tests {

assert!(resource
.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ARCH
opentelemetry_semantic_conventions::attribute::HOST_ARCH
))
.is_some());

#[cfg(target_arch = "x86_64")]
assert_eq!(
resource.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ARCH
opentelemetry_semantic_conventions::attribute::HOST_ARCH
)),
Some(Value::from("x86_64"))
);

#[cfg(target_arch = "aarch64")]
assert_eq!(
resource.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::HOST_ARCH
opentelemetry_semantic_conventions::attribute::HOST_ARCH
)),
Some(Value::from("aarch64"))
)
Expand Down
4 changes: 2 additions & 2 deletions opentelemetry-resource-detectors/src/os.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ pub struct OsResourceDetector;
impl ResourceDetector for OsResourceDetector {
fn detect(&self, _timeout: Duration) -> Resource {
Resource::new(vec![KeyValue::new(
opentelemetry_semantic_conventions::resource::OS_TYPE,
opentelemetry_semantic_conventions::attribute::OS_TYPE,
OS,
)])
}
Expand All @@ -39,7 +39,7 @@ mod tests {
assert_eq!(resource.len(), 1);
assert_eq!(
resource.get(Key::from_static_str(
opentelemetry_semantic_conventions::resource::OS_TYPE
opentelemetry_semantic_conventions::attribute::OS_TYPE
)),
Some(Value::from("linux"))
)
Expand Down
4 changes: 2 additions & 2 deletions opentelemetry-resource-detectors/src/process.rs
Original file line number Diff line number Diff line change
Expand Up @@ -27,11 +27,11 @@ impl ResourceDetector for ProcessResourceDetector {
.collect::<Vec<StringValue>>();
Resource::new(vec![
KeyValue::new(
opentelemetry_semantic_conventions::resource::PROCESS_COMMAND_ARGS,
opentelemetry_semantic_conventions::attribute::PROCESS_COMMAND_ARGS,
Value::Array(cmd_arg_val.into()),
),
KeyValue::new(
opentelemetry_semantic_conventions::resource::PROCESS_PID,
opentelemetry_semantic_conventions::attribute::PROCESS_PID,
id() as i64,
),
])
Expand Down
12 changes: 2 additions & 10 deletions opentelemetry-user-events-metrics/src/exporter/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@ use opentelemetry_proto::tonic::collector::metrics::v1::ExportMetricsServiceRequ
use opentelemetry_sdk::metrics::{
data::{ResourceMetrics, Temporality},
exporter::PushMetricsExporter,
reader::{AggregationSelector, DefaultAggregationSelector, TemporalitySelector},
Aggregation, InstrumentKind,
reader::TemporalitySelector,
InstrumentKind,
};

use crate::tracepoint;
Expand Down Expand Up @@ -52,14 +52,6 @@ impl TemporalitySelector for MetricsExporter {
}
}

impl AggregationSelector for MetricsExporter {
// TODO: this should ideally be done at SDK level by default
// without exporters having to do it.
fn aggregation(&self, kind: InstrumentKind) -> Aggregation {
DefaultAggregationSelector::new().aggregation(kind)
}
}

impl Debug for MetricsExporter {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
f.write_str("user_events metrics exporter")
Expand Down

0 comments on commit 7c131c4

Please sign in to comment.