chore(dev): group imports (#24219)

Author: pront

lib/codecs/src/encoding/serializer.rs

@@ -4,20 +4,22 @@ use bytes::BytesMut;
 use vector_config::configurable_component;
 use vector_core::{config::DataType, event::Event, schema};
 
-use super::chunking::Chunker;
-use super::format::{
-    AvroSerializer, AvroSerializerConfig, AvroSerializerOptions, CefSerializer,
-    CefSerializerConfig, CsvSerializer, CsvSerializerConfig, GelfSerializer, GelfSerializerConfig,
-    JsonSerializer, JsonSerializerConfig, LogfmtSerializer, LogfmtSerializerConfig,
-    NativeJsonSerializer, NativeJsonSerializerConfig, NativeSerializer, NativeSerializerConfig,
-    ProtobufSerializer, ProtobufSerializerConfig, RawMessageSerializer, RawMessageSerializerConfig,
-    TextSerializer, TextSerializerConfig,
-};
 #[cfg(feature = "opentelemetry")]
 use super::format::{OtlpSerializer, OtlpSerializerConfig};
-use super::framing::{
-    CharacterDelimitedEncoderConfig, FramingConfig, LengthDelimitedEncoderConfig,
-    VarintLengthDelimitedEncoderConfig,
+use super::{
+    chunking::Chunker,
+    format::{
+        AvroSerializer, AvroSerializerConfig, AvroSerializerOptions, CefSerializer,
+        CefSerializerConfig, CsvSerializer, CsvSerializerConfig, GelfSerializer,
+        GelfSerializerConfig, JsonSerializer, JsonSerializerConfig, LogfmtSerializer,
+        LogfmtSerializerConfig, NativeJsonSerializer, NativeJsonSerializerConfig, NativeSerializer,
+        NativeSerializerConfig, ProtobufSerializer, ProtobufSerializerConfig, RawMessageSerializer,
+        RawMessageSerializerConfig, TextSerializer, TextSerializerConfig,
+    },
+    framing::{
+        CharacterDelimitedEncoderConfig, FramingConfig, LengthDelimitedEncoderConfig,
+        VarintLengthDelimitedEncoderConfig,
+    },
 };
 
 /// Serializer configuration.

src/sinks/splunk_hec/common/acknowledgements.rs

@@ -1,8 +1,8 @@
 use hyper::Body;
 use serde::{Deserialize, Serialize};
-use std::io::Write;
 use std::{
     collections::HashMap,
+    io::Write,
     num::{NonZeroU8, NonZeroU64},
     sync::Arc,
     time::Duration,
@@ -11,14 +11,14 @@ use tokio::sync::{mpsc::Receiver, oneshot::Sender};
 use vector_lib::{configurable::configurable_component, event::EventStatus};
 
 use super::service::{HttpRequestBuilder, MetadataFields};
-use crate::sinks::util::Compressor;
 use crate::{
     config::AcknowledgementsConfig,
     http::HttpClient,
     internal_events::{
         SplunkIndexerAcknowledgementAPIError, SplunkIndexerAcknowledgementAckAdded,
         SplunkIndexerAcknowledgementAcksRemoved,
     },
+    sinks::util::Compressor,
 };
 
 /// Splunk HEC acknowledgement configuration.

tests/e2e/opentelemetry/logs/mod.rs

@@ -1,6 +1,7 @@
-use vector_lib::opentelemetry::proto::LOGS_REQUEST_MESSAGE_TYPE;
-use vector_lib::opentelemetry::proto::collector::logs::v1::ExportLogsServiceRequest;
-use vector_lib::opentelemetry::proto::common::v1::any_value::Value as AnyValueEnum;
+use vector_lib::opentelemetry::proto::{
+    LOGS_REQUEST_MESSAGE_TYPE, collector::logs::v1::ExportLogsServiceRequest,
+    common::v1::any_value::Value as AnyValueEnum,
+};
 
 use crate::opentelemetry::{
     assert_service_name_with, parse_line_to_export_type_request, read_file_helper,

tests/e2e/opentelemetry/metrics/mod.rs

@@ -2,12 +2,12 @@ use crate::opentelemetry::{
     assert_service_name_with, parse_line_to_export_type_request, read_file_helper,
 };
 
-use vector_lib::opentelemetry::proto::METRICS_REQUEST_MESSAGE_TYPE;
-use vector_lib::opentelemetry::proto::collector::metrics::v1::ExportMetricsServiceRequest;
-use vector_lib::opentelemetry::proto::common::v1::KeyValue;
-use vector_lib::opentelemetry::proto::common::v1::any_value::Value as AnyValueEnum;
-use vector_lib::opentelemetry::proto::metrics::v1::metric::Data as MetricData;
-use vector_lib::opentelemetry::proto::metrics::v1::{Gauge, Sum};
+use vector_lib::opentelemetry::proto::{
+    METRICS_REQUEST_MESSAGE_TYPE,
+    collector::metrics::v1::ExportMetricsServiceRequest,
+    common::v1::{KeyValue, any_value::Value as AnyValueEnum},
+    metrics::v1::{Gauge, Sum, metric::Data as MetricData},
+};
 
 const EXPECTED_METRIC_COUNT: usize = 400; // 200 via gRPC + 200 via HTTP (50 of each type: Gauge, Sum, Histogram, ExponentialHistogram)
 

vdev/src/commands/build/publish_metadata.rs

@@ -2,9 +2,11 @@ use anyhow::Result;
 use chrono::prelude::*;
 
 use crate::utils::{cargo, git};
-use std::env;
-use std::fs::OpenOptions;
-use std::io::{self, Write};
+use std::{
+    env,
+    fs::OpenOptions,
+    io::{self, Write},
+};
 
 /// Setting necessary metadata for our publish workflow in CI.
 ///

vdev/src/commands/check/markdown.rs

@@ -1,7 +1,6 @@
 use anyhow::Result;
 
-use crate::app;
-use crate::utils::git::git_ls_files;
+use crate::{app, utils::git::git_ls_files};
 
 /// Check that markdown is styled properly
 #[derive(clap::Args, Debug)]

vdev/src/commands/check/rust.rs

@@ -1,7 +1,10 @@
 use anyhow::Result;
 use std::ffi::OsString;
 
-use crate::{app, utils::command::ChainArgs as _, utils::git};
+use crate::{
+    app,
+    utils::{command::ChainArgs as _, git},
+};
 
 /// Check the Rust code for errors
 #[derive(clap::Args, Debug)]

vdev/src/commands/crate_versions.rs

@@ -1,4 +1,7 @@
-use std::{collections::HashMap, collections::HashSet, process::Command};
+use std::{
+    collections::{HashMap, HashSet},
+    process::Command,
+};
 
 use anyhow::Result;
 use clap::Args;

vdev/src/commands/e2e/show.rs

@@ -1,5 +1,7 @@
-use crate::commands::compose_tests::show::{exec, exec_environments_only};
-use crate::testing::config::E2E_TESTS_DIR;
+use crate::{
+    commands::compose_tests::show::{exec, exec_environments_only},
+    testing::config::E2E_TESTS_DIR,
+};
 use anyhow::Result;
 use clap::Args;
 

vdev/src/commands/info.rs

@@ -1,8 +1,7 @@
 use anyhow::Result;
 use clap::Args;
 
-use crate::testing::docker::CONTAINER_TOOL;
-use crate::{app, utils::platform};
+use crate::{app, testing::docker::CONTAINER_TOOL, utils::platform};
 
 /// Show `vdev` command configuration
 #[derive(Args, Debug)]