Format server.rs and http_metrics.rs

src/cli/command/server.rs

@@ -7,7 +7,10 @@ use std::{
     sync::{Arc, RwLock},
 };
 
-use actix_web::{middleware::{self, from_fn}, web, App, HttpResponse, HttpServer};
+use actix_web::{
+    middleware::{self, from_fn},
+    web, App, HttpResponse, HttpServer,
+};
 use anyhow::format_err;
 use clap::ArgMatches;
 use openssl::{
@@ -17,7 +20,12 @@ use openssl::{
 use sysexits::ExitCode;
 
 use crate::{
-    cli::config, core::Core, errors::RvError, http, metrics::{manager::MetricsManager, middleware::metrics_midleware}, storage, EXIT_CODE_INSUFFICIENT_PARAMS, EXIT_CODE_LOAD_CONFIG_FAILURE, EXIT_CODE_OK
+    cli::config,
+    core::Core,
+    errors::RvError,
+    http,
+    metrics::{manager::MetricsManager, middleware::metrics_midleware},
+    storage, EXIT_CODE_INSUFFICIENT_PARAMS, EXIT_CODE_LOAD_CONFIG_FAILURE, EXIT_CODE_OK,
 };
 
 pub const WORK_DIR_PATH_DEFAULT: &str = "/tmp/rusty_vault";
@@ -111,7 +119,6 @@ pub fn main(config_path: &str) -> Result<(), RvError> {
     let metrics_manager = Arc::new(RwLock::new(MetricsManager::new()));
     let system_metrics = Arc::clone(&metrics_manager.read().unwrap().system_metrics);
 
-
     let core = Arc::new(RwLock::new(Core {
         physical: backend,
         barrier: Arc::new(barrier),

src/metrics/http_metrics.rs

@@ -43,9 +43,8 @@ pub struct HttpMetrics {
 impl HttpMetrics {
     pub fn new(registry: &mut Registry) -> Self {
         let requests = Family::<HttpLabel, Counter>::default();
-        let histogram = Family::<HttpLabel, Histogram>::new_with_constructor(|| {
-           Histogram::new(linear_buckets(0.1, 0.1, 10))
-        });
+        let histogram =
+            Family::<HttpLabel, Histogram>::new_with_constructor(|| Histogram::new(linear_buckets(0.1, 0.1, 10)));
 
         registry.register(
             "http_request_count",
@@ -62,11 +61,11 @@ impl HttpMetrics {
         Self { requests, histogram }
     }
 
-    pub fn increment_request_count(&self, label:&HttpLabel) {
+    pub fn increment_request_count(&self, label: &HttpLabel) {
         self.requests.get_or_create(label).inc();
     }
 
-    pub fn observe_duration(&self, label:&HttpLabel, duration: f64,) {
+    pub fn observe_duration(&self, label: &HttpLabel, duration: f64) {
         self.histogram.get_or_create(label).observe(duration);
     }
 }