chore(dev): bump rust toolchain to 1.95 and fix clippy lints (#25606)

* chore: bump rust toolchain to 1.95 and fix clippy lints

* fix(websocket sink): handle Auth::Bearer match exhaustiveness without aws-core

* Add HTTP Version fallback

---------

Co-authored-by: Pavlos Rontidis <pavlos.rontidis@gmail.com>

Author: thomasqueirozb

lib/codecs/tests/native.rs

@@ -202,7 +202,7 @@ fn rebuild_proto_fixtures() {
 fn fixtures_match(suffix: &str) {
     let json_entries = list_fixtures("json", suffix);
     let proto_entries = list_fixtures("proto", suffix);
-    for (json_path, proto_path) in json_entries.into_iter().zip(proto_entries.into_iter()) {
+    for (json_path, proto_path) in json_entries.into_iter().zip(proto_entries) {
         // Make sure we're looking at the matching files for each format
         assert_eq!(
             json_path.file_stem().unwrap(),
@@ -220,7 +220,7 @@ fn decoding_matches(suffix: &str) {
     let json_entries = list_fixtures("json", suffix);
     let proto_entries = list_fixtures("proto", suffix);
 
-    for (json_path, proto_path) in json_entries.into_iter().zip(proto_entries.into_iter()) {
+    for (json_path, proto_path) in json_entries.into_iter().zip(proto_entries) {
         let (_, json_event) = load_deserialize(&json_path, &json_deserializer);
 
         let (_, proto_event) = load_deserialize(&proto_path, &proto_deserializer);

lib/vector-buffers/src/variants/disk_v2/common.rs

@@ -339,7 +339,7 @@ where
         if max_record_size <= MINIMUM_MAX_RECORD_SIZE {
             return Err(BuildError::InvalidParameter {
                 param_name: "max_record_size",
-                reason: format!("must be greater than or equal to {MINIMUM_MAX_RECORD_SIZE} bytes",),
+                reason: format!("must be greater than or equal to {MINIMUM_MAX_RECORD_SIZE} bytes"),
             });
         }
 

lib/vector-buffers/src/variants/disk_v2/ledger.rs

@@ -471,7 +471,7 @@ where
         );
 
         trace!(
-            unacked_reader_file_id_offset = result.map(|n| n - 1).unwrap_or(0),
+            unacked_reader_file_id_offset = result.map_or(0, |n| n - 1),
             acked_reader_file_id_offset = new_reader_file_id,
             "Incremented acknowledged reader file ID offset with corresponding unacknowledged decrement."
         );

lib/vector-config/src/schema/visitors/merge.rs

@@ -262,7 +262,7 @@ where
     K: Clone + Eq + Ord,
     V: Clone + Mergeable,
 {
-    destination.merge(source);
+    Mergeable::merge(destination, source);
 }
 
 fn merge_optional<T: Clone>(destination: &mut Option<T>, source: Option<&T>) {

lib/vector-core/src/config/global_options.rs

@@ -217,9 +217,8 @@ impl GlobalOptions {
         if !data_dir.exists() {
             return Err(DataDirError::DoesNotExist { data_dir }.into());
         }
-        let readonly = std::fs::metadata(&data_dir)
-            .map(|meta| meta.permissions().readonly())
-            .unwrap_or(true);
+        let readonly =
+            std::fs::metadata(&data_dir).map_or(true, |meta| meta.permissions().readonly());
         if readonly {
             return Err(DataDirError::NotWritable { data_dir }.into());
         }

lib/vector-core/src/config/mod.rs

@@ -197,7 +197,7 @@ fn fmt_helper(
     data_type: DataType,
 ) -> fmt::Result {
     match maybe_port {
-        Some(port) => write!(f, "port: \"{port}\",",),
+        Some(port) => write!(f, "port: \"{port}\","),
         None => write!(f, "port: None,"),
     }?;
     write!(f, " types: {data_type}")

lib/vector-core/src/event/lua/metric.rs

@@ -163,7 +163,7 @@ impl IntoLua for LuaMetric {
             }
             MetricValue::Set { values } => {
                 let set = lua.create_table()?;
-                set.raw_set("values", lua.create_sequence_from(values.into_iter())?)?;
+                set.raw_set("values", lua.create_sequence_from(values)?)?;
                 tbl.raw_set("set", set)?;
             }
             MetricValue::Distribution { samples, statistic } => {

lib/vector-core/src/event/metadata.rs

@@ -381,10 +381,8 @@ impl EventMetadata {
 
         // Keep the earliest `last_transform_timestamp` for accurate latency measurement.
         match (self.last_transform_timestamp, other_timestamp) {
-            (Some(self_ts), Some(other_ts)) => {
-                if other_ts < self_ts {
-                    self.last_transform_timestamp = Some(other_ts);
-                }
+            (Some(self_ts), Some(other_ts)) if other_ts < self_ts => {
+                self.last_transform_timestamp = Some(other_ts);
             }
             (None, Some(other_ts)) => {
                 self.last_transform_timestamp = Some(other_ts);

lib/vector-core/src/event/metric/mod.rs

@@ -334,8 +334,8 @@ impl Metric {
     /// Returns `true` if `name` tag is present, and matches the provided `value`
     pub fn tag_matches(&self, name: &str, value: &str) -> bool {
         self.tags()
-            .filter(|t| t.get(name).filter(|v| *v == value).is_some())
-            .is_some()
+            .as_ref()
+            .is_some_and(|t| t.get(name).as_ref().is_some_and(|v| *v == value))
     }
 
     /// Returns the string value of a tag, if it exists

lib/vector-core/src/metrics/ddsketch.rs

@@ -407,7 +407,7 @@ impl AgentDDSketch {
 
     fn insert_key_counts(&mut self, mut counts: Vec<(i16, u32)>) {
         // Counts need to be sorted by key.
-        counts.sort_unstable_by(|(k1, _), (k2, _)| k1.cmp(k2));
+        counts.sort_unstable_by_key(|(k1, _)| *k1);
 
         let mut temp = Vec::new();