fmt changes

Author: nikhilsinhaparseable

src/storage/localfs.rs

@@ -137,7 +137,11 @@ impl ObjectStorage for LocalFS {
             1,
             &Utc::now().date_naive().to_string(),
         );
-        increment_object_store_calls_by_date("localfs", "HEAD", &Utc::now().date_naive().to_string());
+        increment_object_store_calls_by_date(
+            "localfs",
+            "HEAD",
+            &Utc::now().date_naive().to_string(),
+        );
         Err(ObjectStorageError::UnhandledError(Box::new(
             std::io::Error::new(
                 std::io::ErrorKind::Unsupported,
@@ -164,7 +168,11 @@ impl ObjectStorage for LocalFS {
                     1,
                     &Utc::now().date_naive().to_string(),
                 );
-                increment_object_store_calls_by_date("localfs", "GET", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "GET",
+                    &Utc::now().date_naive().to_string(),
+                );
                 Ok(x.into())
             }
             Err(e) => {
@@ -234,8 +242,13 @@ impl ObjectStorage for LocalFS {
             "localfs",
             "LIST",
             files_scanned,
-            &Utc::now().date_naive().to_string());
-        increment_object_store_calls_by_date("localfs", "LIST", &Utc::now().date_naive().to_string());
+            &Utc::now().date_naive().to_string(),
+        );
+        increment_object_store_calls_by_date(
+            "localfs",
+            "LIST",
+            &Utc::now().date_naive().to_string(),
+        );
         Ok(path_arr)
     }
 
@@ -423,7 +436,11 @@ impl ObjectStorage for LocalFS {
                     1,
                     &Utc::now().date_naive().to_string(),
                 );
-                increment_object_store_calls_by_date("localfs", "PUT", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "PUT",
+                    &Utc::now().date_naive().to_string(),
+                );
             }
             Err(_) => {
                 STORAGE_REQUEST_RESPONSE_TIME
@@ -483,7 +500,11 @@ impl ObjectStorage for LocalFS {
                     1,
                     &Utc::now().date_naive().to_string(),
                 );
-                increment_object_store_calls_by_date("localfs", "DELETE", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "DELETE",
+                    &Utc::now().date_naive().to_string(),
+                );
             }
             Err(err) => {
                 let status_code = match err.kind() {
@@ -511,7 +532,11 @@ impl ObjectStorage for LocalFS {
                 STORAGE_REQUEST_RESPONSE_TIME
                     .with_label_values(&["localfs", "HEAD", "200"])
                     .observe(check_elapsed);
-                increment_object_store_calls_by_date("localfs", "HEAD", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "HEAD",
+                    &Utc::now().date_naive().to_string(),
+                );
             }
             Err(err) => {
                 let status_code = match err.kind() {
@@ -603,7 +628,11 @@ impl ObjectStorage for LocalFS {
                 STORAGE_REQUEST_RESPONSE_TIME
                     .with_label_values(&["localfs", "LIST", "200"])
                     .observe(list_elapsed);
-                increment_object_store_calls_by_date("localfs", "LIST", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "LIST",
+                    &Utc::now().date_naive().to_string(),
+                );
                 ReadDirStream::new(read_dir)
             }
             Err(err) => {
@@ -650,7 +679,11 @@ impl ObjectStorage for LocalFS {
                 STORAGE_REQUEST_RESPONSE_TIME
                     .with_label_values(&["localfs", "LIST", "200"])
                     .observe(list_elapsed);
-                increment_object_store_calls_by_date("localfs", "LIST", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "LIST",
+                    &Utc::now().date_naive().to_string(),
+                );
                 ReadDirStream::new(read_dir)
             }
             Err(err) => {
@@ -778,7 +811,11 @@ impl ObjectStorage for LocalFS {
                 STORAGE_REQUEST_RESPONSE_TIME
                     .with_label_values(&["localfs", "LIST", "200"])
                     .observe(list_elapsed);
-                increment_object_store_calls_by_date("localfs", "LIST", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "LIST",
+                    &Utc::now().date_naive().to_string(),
+                );
                 read_dir
             }
             Err(err) => {
@@ -867,7 +904,11 @@ impl ObjectStorage for LocalFS {
                 STORAGE_REQUEST_RESPONSE_TIME
                     .with_label_values(&["localfs", "PUT", "200"])
                     .observe(upload_elapsed);
-                increment_object_store_calls_by_date("localfs", "PUT", &Utc::now().date_naive().to_string());
+                increment_object_store_calls_by_date(
+                    "localfs",
+                    "PUT",
+                    &Utc::now().date_naive().to_string(),
+                );
                 Ok(())
             }
             Err(err) => {