chore(dev): upgrade Rust to 1.91.1

lib/vector-common/src/finalization.rs

@@ -280,23 +280,19 @@ impl Drop for OwnedBatchNotifier {
 /// The status of an individual batch.
 #[derive(Copy, Clone, Debug, Eq, PartialEq)]
 #[repr(u8)]
+#[derive(Default)]
 pub enum BatchStatus {
     /// All events in the batch were accepted.
     ///
     /// This is the default.
+    #[default]
     Delivered,
     /// At least one event in the batch had a transient error in delivery.
     Errored,
     /// At least one event in the batch had a permanent failure or rejection.
     Rejected,
 }
 
-impl Default for BatchStatus {
-    fn default() -> Self {
-        Self::Delivered
-    }
-}
-
 impl BatchStatus {
     /// Updates the delivery status based on another batch's delivery status, returning the result.
     ///
@@ -320,10 +316,12 @@ impl BatchStatus {
 /// The status of an individual event.
 #[derive(Copy, Clone, Debug, Eq, PartialEq)]
 #[repr(u8)]
+#[derive(Default)]
 pub enum EventStatus {
     /// All copies of this event were dropped without being finalized.
     ///
     /// This is the default.
+    #[default]
     Dropped,
     /// All copies of this event were delivered successfully.
     Delivered,
@@ -335,12 +333,6 @@ pub enum EventStatus {
     Recorded,
 }
 
-impl Default for EventStatus {
-    fn default() -> Self {
-        Self::Dropped
-    }
-}
-
 impl EventStatus {
     /// Updates the status based on another event's status, returning the result.
     ///

lib/vector-config-macros/src/lib.rs

@@ -10,7 +10,7 @@ mod configurable_component;
 
 /// Designates a type as being part of a Vector configuration.
 ///
-/// This will automatically derive the [`Configurable`][vector-config::Configurable] trait for the given struct/enum, as
+/// This will automatically derive the `Configurable` trait for the given struct/enum, as
 /// well as ensuring that serialization/deserialization (via `serde`) is derived.
 ///
 /// ## Basics

lib/vector-config/src/named.rs

@@ -1,7 +1,7 @@
 /// A component with a well-known name.
 ///
 /// Users can derive this trait automatically by using the
-/// [`component_name`][vector-config::component_name] macro on their structs/enums.
+/// [`NamedComponent`][derive@crate::NamedComponent] derive macro on their structs/enums.
 pub trait NamedComponent {
     /// Gets the name of the component.
     fn get_component_name(&self) -> &'static str;

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

@@ -393,7 +393,7 @@ impl From<bool> for AcknowledgementsConfig {
     }
 }
 
-#[derive(Debug, Copy, Clone, PartialEq, Serialize, Deserialize, PartialOrd, Ord, Eq)]
+#[derive(Debug, Copy, Clone, PartialEq, Serialize, Deserialize, PartialOrd, Ord, Eq, Default)]
 pub enum LogNamespace {
     /// Vector native namespacing
     ///
@@ -405,6 +405,7 @@ pub enum LogNamespace {
     ///
     /// All data is set in the root of the event. Since this can lead
     /// to collisions, deserialized data has priority over metadata
+    #[default]
     Legacy,
 }
 
@@ -420,12 +421,6 @@ impl From<bool> for LogNamespace {
     }
 }
 
-impl Default for LogNamespace {
-    fn default() -> Self {
-        Self::Legacy
-    }
-}
-
 /// A shortcut to specify no `LegacyKey` should be used (since otherwise a turbofish would be required)
 pub const NO_LEGACY_KEY: Option<LegacyKey<&'static str>> = None;
 

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

@@ -88,7 +88,7 @@ impl FromLua for TagValueSet {
                 }
                 Ok(Self::from(string_values))
             }
-            LuaValue::String(x) => Ok(Self::from([x.to_string_lossy().to_string()])),
+            LuaValue::String(x) => Ok(Self::from([x.to_string_lossy().clone()])),
             _ => Err(mlua::Error::FromLuaConversionError {
                 from: value.type_name(),
                 to: String::from("metric tag value"),

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

@@ -94,9 +94,10 @@ type TagValueRef<'a> = Option<&'a str>;
 
 /// Tag values for a metric series.  This may be empty, a single value, or a set of values. This is
 /// used to provide the storage for `TagValueSet`.
-#[derive(Clone, Configurable, Debug, Eq, PartialEq)]
+#[derive(Clone, Configurable, Debug, Eq, PartialEq, Default)]
 pub enum TagValueSet {
     /// This represents a set containing no value.
+    #[default]
     Empty,
 
     /// This represents a set containing a single value. This is stored separately to avoid the
@@ -111,12 +112,6 @@ pub enum TagValueSet {
     Set(IndexSet<TagValue>),
 }
 
-impl Default for TagValueSet {
-    fn default() -> Self {
-        Self::Empty
-    }
-}
-
 impl Display for TagValueSet {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         for (i, value) in self.iter().enumerate() {

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "1.90"
+channel = "1.91"
 profile = "default"

src/sinks/databend/compression.rs

@@ -7,18 +7,14 @@ use vector_lib::configurable::configurable_component;
 #[configurable(metadata(
     docs::enum_tag_description = "The compression algorithm to use for sending."
 ))]
+#[derive(Default)]
 pub enum DatabendCompression {
     /// No compression.
+    #[default]
     None,
 
     /// [Gzip][gzip] compression.
     ///
     /// [gzip]: https://www.gzip.org/
     Gzip,
 }
-
-impl Default for DatabendCompression {
-    fn default() -> Self {
-        Self::None
-    }
-}

src/sinks/databend/encoding.rs

@@ -75,11 +75,13 @@ impl DatabendEncodingConfig {
 #[derive(Clone, Debug)]
 #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
 #[configurable(metadata(docs::enum_tag_description = "How to handle missing fields for NDJson."))]
+#[derive(Default)]
 pub enum DatabendMissingFieldAS {
     /// Generates an error if a missing field is encountered.
     Error,
 
     /// Interprets missing fields as NULL values. An error will be generated for non-nullable fields.
+    #[default]
     Null,
 
     /// Uses the default value of the field for missing fields.
@@ -89,12 +91,6 @@ pub enum DatabendMissingFieldAS {
     TypeDefault,
 }
 
-impl Default for DatabendMissingFieldAS {
-    fn default() -> Self {
-        Self::Null
-    }
-}
-
 impl DatabendMissingFieldAS {
     pub(super) const fn as_str(&self) -> &'static str {
         match self {

src/sinks/elasticsearch/config.rs

@@ -46,8 +46,10 @@ pub const DATA_STREAM_TIMESTAMP_KEY: &str = "@timestamp";
 #[configurable_component]
 #[derive(Clone, Debug, Eq, PartialEq)]
 #[serde(deny_unknown_fields, rename_all = "lowercase")]
+#[derive(Default)]
 pub enum OpenSearchServiceType {
     /// Elasticsearch or OpenSearch Managed domain
+    #[default]
     Managed,
     /// OpenSearch Serverless collection
     Serverless,
@@ -62,12 +64,6 @@ impl OpenSearchServiceType {
     }
 }
 
-impl Default for OpenSearchServiceType {
-    fn default() -> Self {
-        Self::Managed
-    }
-}
-
 /// Configuration for the `elasticsearch` sink.
 #[configurable_component(sink("elasticsearch", "Index observability events in Elasticsearch."))]
 #[derive(Clone, Debug)]

src/sinks/elasticsearch/mod.rs

@@ -61,9 +61,11 @@ pub enum ElasticsearchAuthConfig {
 #[configurable_component]
 #[derive(Clone, Debug, Eq, PartialEq)]
 #[serde(deny_unknown_fields, rename_all = "snake_case")]
+#[derive(Default)]
 pub enum ElasticsearchMode {
     /// Ingests documents in bulk, using the bulk API `index` action.
     #[serde(alias = "normal")]
+    #[default]
     Bulk,
 
     /// Ingests documents in bulk, using the bulk API `create` action.
@@ -75,12 +77,6 @@ pub enum ElasticsearchMode {
     DataStream,
 }
 
-impl Default for ElasticsearchMode {
-    fn default() -> Self {
-        Self::Bulk
-    }
-}
-
 /// Bulk API actions.
 #[configurable_component]
 #[derive(Clone, Copy, Debug, Derivative, Eq, Hash, PartialEq)]
@@ -295,6 +291,7 @@ impl ElasticsearchCommonMode {
 #[derive(Clone, Debug, Eq, PartialEq)]
 #[cfg_attr(feature = "proptest", derive(proptest_derive::Arbitrary))]
 #[serde(deny_unknown_fields, rename_all = "snake_case")]
+#[derive(Default)]
 pub enum ElasticsearchApiVersion {
     /// Auto-detect the API version.
     ///
@@ -305,6 +302,7 @@ pub enum ElasticsearchApiVersion {
     /// incorrect API calls.
     ///
     /// [es_version]: https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-state.html#cluster-state-api-path-params
+    #[default]
     Auto,
     /// Use the Elasticsearch 6.x API.
     V6,
@@ -314,12 +312,6 @@ pub enum ElasticsearchApiVersion {
     V8,
 }
 
-impl Default for ElasticsearchApiVersion {
-    fn default() -> Self {
-        Self::Auto
-    }
-}
-
 #[derive(Debug, Snafu)]
 #[snafu(visibility(pub))]
 pub enum ParseError {

src/sinks/prometheus/exporter.rs

@@ -1186,7 +1186,7 @@ mod tests {
             },
         );
 
-        let metrics = vec![
+        let metrics = [
             base_summary_metric.clone(),
             base_summary_metric
                 .clone()
@@ -1305,7 +1305,7 @@ mod tests {
             },
         );
 
-        let metrics = vec![
+        let metrics = [
             base_summary_metric.clone(),
             base_summary_metric
                 .clone()
@@ -1406,7 +1406,7 @@ mod tests {
             MetricValue::Gauge { value: -10.0 },
         );
 
-        let metrics = vec![
+        let metrics = [
             base_absolute_gauge_metric.clone(),
             base_absolute_gauge_metric
                 .clone()

src/sinks/util/service/concurrency.rs

@@ -18,7 +18,7 @@ use vector_lib::configurable::{
 ///
 /// This can be set either to one of the below enum values or to a positive integer, which denotes
 /// a fixed concurrency limit.
-#[derive(Clone, Copy, Debug, Derivative, Eq, PartialEq)]
+#[derive(Clone, Copy, Debug, Derivative, Eq, PartialEq, Default)]
 pub enum Concurrency {
     /// A fixed concurrency of 1.
     ///
@@ -28,6 +28,7 @@ pub enum Concurrency {
     /// Concurrency is managed by the [Adaptive Request Concurrency][arc] feature.
     ///
     /// [arc]: https://vector.dev/docs/architecture/arc/
+    #[default]
     Adaptive,
 
     /// A fixed amount of concurrency is allowed.
@@ -47,12 +48,6 @@ impl Serialize for Concurrency {
     }
 }
 
-impl Default for Concurrency {
-    fn default() -> Self {
-        Self::Adaptive
-    }
-}
-
 impl Concurrency {
     pub const fn parse_concurrency(&self) -> Option<usize> {
         match self {

src/sources/fluent/mod.rs

@@ -926,7 +926,7 @@ mod tests {
             250, 129, 167, 109, 101, 115, 115, 97, 103, 101, 163, 98, 97, 122,
         ];
 
-        let expected = vec![
+        let expected = [
             mock_event("foo", "2015-09-07T01:23:04Z"),
             mock_event("bar", "2015-09-07T01:23:05Z"),
             mock_event("baz", "2015-09-07T01:23:06Z"),
@@ -958,7 +958,7 @@ mod tests {
             122, 101, 3,
         ];
 
-        let expected = vec![
+        let expected = [
             mock_event("foo", "2015-09-07T01:23:04Z"),
             mock_event("bar", "2015-09-07T01:23:05Z"),
             mock_event("baz", "2015-09-07T01:23:06Z"),
@@ -992,7 +992,7 @@ mod tests {
             101, 115, 115, 97, 103, 101, 163, 102, 111, 111,
         ];
 
-        let expected = vec![
+        let expected = [
             mock_event("foo", "2015-09-07T01:23:04Z"),
             mock_event("bar", "2015-09-07T01:23:05Z"),
             mock_event("baz", "2015-09-07T01:23:06Z"),
@@ -1027,7 +1027,7 @@ mod tests {
             164, 103, 122, 105, 112,
         ];
 
-        let expected = vec![
+        let expected = [
             mock_event("foo", "2015-09-07T01:23:04Z"),
             mock_event("bar", "2015-09-07T01:23:05Z"),
             mock_event("baz", "2015-09-07T01:23:06Z"),

src/sources/util/grpc/decompression.rs

@@ -66,16 +66,16 @@ impl CompressionScheme {
     }
 }
 
+#[derive(Default)]
 enum State {
+    #[default]
     WaitingForHeader,
-    Forward { overall_len: usize },
-    Decompress { remaining: usize },
-}
-
-impl Default for State {
-    fn default() -> Self {
-        Self::WaitingForHeader
-    }
+    Forward {
+        overall_len: usize,
+    },
+    Decompress {
+        remaining: usize,
+    },
 }
 
 fn new_decompressor() -> GzDecoder<Vec<u8>> {