fixed cargo fmt

Author: nikhilsinhaparseable

server/src/handlers/http/ingest.rs

@@ -21,15 +21,15 @@ use arrow_schema::Field;
 use bytes::Bytes;
 use http::StatusCode;
 use serde_json::Value;
-use std::collections::{BTreeMap,HashMap};
+use std::collections::{BTreeMap, HashMap};
 use std::sync::Arc;
 
 use crate::event::error::EventError;
 use crate::event::format::EventFormat;
 use crate::event::{self, format};
 use crate::handlers::{
-    LOG_SOURCE_KEY, PREFIX_META, PREFIX_TAGS, SEPARATOR, STREAM_NAME_HEADER_KEY, 
-    LOG_SOURCE_VALUE_FOR_KINEIS, LOG_SOURCE_VALUE_FOR_OTEL
+    LOG_SOURCE_KEY, LOG_SOURCE_VALUE_FOR_KINEIS, LOG_SOURCE_VALUE_FOR_OTEL, PREFIX_META,
+    PREFIX_TAGS, SEPARATOR, STREAM_NAME_HEADER_KEY,
 };
 use crate::metadata::STREAM_INFO;
 use crate::utils::header_parsing::{collect_labelled_headers, ParseHeaderError};

server/src/handlers/http/middleware.rs

@@ -28,8 +28,8 @@ use actix_web::{
 use futures_util::future::LocalBoxFuture;
 
 use crate::handlers::{
-    AUTHORIZATION_KEY, KINESIS_COMMON_ATTRIBUTES_KEY, LOG_SOURCE_KEY, 
-    STREAM_NAME_HEADER_KEY, LOG_SOURCE_VALUE_FOR_KINEIS
+    AUTHORIZATION_KEY, KINESIS_COMMON_ATTRIBUTES_KEY, LOG_SOURCE_KEY, LOG_SOURCE_VALUE_FOR_KINEIS,
+    STREAM_NAME_HEADER_KEY,
 };
 use crate::{
     option::CONFIG,