From 6dd50a8d71c486a1d4237e25bc50a4d2d68dfb36 Mon Sep 17 00:00:00 2001 From: Kevin Sun Date: Wed, 30 Apr 2025 10:04:18 +1000 Subject: [PATCH] DWN-4598 merge-upstream-RUSTSEC-2024-0437-fix --- opentelemetry-prometheus/Cargo.toml | 3 +-- opentelemetry-prometheus/src/lib.rs | 30 ++++++++++++++--------------- 2 files changed, 16 insertions(+), 17 deletions(-) diff --git a/opentelemetry-prometheus/Cargo.toml b/opentelemetry-prometheus/Cargo.toml index 037e48f381..284983b61f 100644 --- a/opentelemetry-prometheus/Cargo.toml +++ b/opentelemetry-prometheus/Cargo.toml @@ -23,8 +23,7 @@ rustdoc-args = ["--cfg", "docsrs"] once_cell = "1.17" opentelemetry = { version = "0.21", path = "../opentelemetry", default-features = false, features = ["metrics"] } opentelemetry_sdk = { version = "0.20", path = "../opentelemetry-sdk", default-features = false, features = ["metrics"] } -prometheus = "0.13" -protobuf = "2.14" +prometheus = "0.14" [dev-dependencies] opentelemetry-semantic-conventions = { path = "../opentelemetry-semantic-conventions" } diff --git a/opentelemetry-prometheus/src/lib.rs b/opentelemetry-prometheus/src/lib.rs index dcd008c071..fe64a71496 100644 --- a/opentelemetry-prometheus/src/lib.rs +++ b/opentelemetry-prometheus/src/lib.rs @@ -413,9 +413,9 @@ fn validate_metrics( global::handle_error(MetricsError::Other(format!("Instrument type conflict, using existing type definition. Instrument {name}, Existing: {:?}, dropped: {:?}", existing.get_field_type(), metric_type))); return (true, None); } - if existing.get_help() != description { - global::handle_error(MetricsError::Other(format!("Instrument description conflict, using existing. Instrument {name}, Existing: {:?}, dropped: {:?}", existing.get_help(), description))); - return (false, Some(existing.get_help().to_string())); + if existing.help() != description { + global::handle_error(MetricsError::Other(format!("Instrument description conflict, using existing. Instrument {name}, Existing: {:?}, dropped: {:?}", existing.help(), description))); + return (false, Some(existing.help().to_string())); } (false, None) } else { @@ -458,16 +458,16 @@ fn add_histogram_metric( let mut h = prometheus::proto::Histogram::default(); h.set_sample_sum(dp.sum.as_f64()); h.set_sample_count(dp.count); - h.set_bucket(protobuf::RepeatedField::from_vec(bucket)); + h.set_bucket(bucket); let mut pm = prometheus::proto::Metric::default(); - pm.set_label(protobuf::RepeatedField::from_vec(kvs)); + pm.set_label(kvs); pm.set_histogram(h); let mut mf = prometheus::proto::MetricFamily::default(); mf.set_name(name.to_string()); mf.set_help(description.clone()); mf.set_field_type(prometheus::proto::MetricType::HISTOGRAM); - mf.set_metric(protobuf::RepeatedField::from_vec(vec![pm])); + mf.set_metric(vec![pm]); res.push(mf); } } @@ -489,7 +489,7 @@ fn add_sum_metric( let kvs = get_attrs(&mut dp.attributes.iter(), extra); let mut pm = prometheus::proto::Metric::default(); - pm.set_label(protobuf::RepeatedField::from_vec(kvs)); + pm.set_label(kvs); if sum.is_monotonic { let mut c = prometheus::proto::Counter::default(); @@ -505,7 +505,7 @@ fn add_sum_metric( mf.set_name(name.to_string()); mf.set_help(description.clone()); mf.set_field_type(metric_type); - mf.set_metric(protobuf::RepeatedField::from_vec(vec![pm])); + mf.set_metric(vec![pm]); res.push(mf); } } @@ -523,14 +523,14 @@ fn add_gauge_metric( let mut g = prometheus::proto::Gauge::default(); g.set_value(dp.value.as_f64()); let mut pm = prometheus::proto::Metric::default(); - pm.set_label(protobuf::RepeatedField::from_vec(kvs)); + pm.set_label(kvs); pm.set_gauge(g); let mut mf = prometheus::proto::MetricFamily::default(); mf.set_name(name.to_string()); mf.set_help(description.to_string()); mf.set_field_type(MetricType::GAUGE); - mf.set_metric(protobuf::RepeatedField::from_vec(vec![pm])); + mf.set_metric(vec![pm]); res.push(mf); } } @@ -544,17 +544,17 @@ fn create_info_metric( g.set_value(1.0); let mut m = prometheus::proto::Metric::default(); - m.set_label(protobuf::RepeatedField::from_vec(get_attrs( + m.set_label(get_attrs( &mut resource.iter(), &[], - ))); + )); m.set_gauge(g); let mut mf = MetricFamily::default(); mf.set_name(target_info_name.into()); mf.set_help(target_info_description.into()); mf.set_field_type(MetricType::GAUGE); - mf.set_metric(protobuf::RepeatedField::from_vec(vec![m])); + mf.set_metric(vec![m]); mf } @@ -575,14 +575,14 @@ fn create_scope_info_metric(scope: &Scope) -> MetricFamily { } let mut m = prometheus::proto::Metric::default(); - m.set_label(protobuf::RepeatedField::from_vec(labels)); + m.set_label(labels); m.set_gauge(g); let mut mf = MetricFamily::default(); mf.set_name(SCOPE_INFO_METRIC_NAME.into()); mf.set_help(SCOPE_INFO_DESCRIPTION.into()); mf.set_field_type(MetricType::GAUGE); - mf.set_metric(protobuf::RepeatedField::from_vec(vec![m])); + mf.set_metric(vec![m]); mf }