Cargo fmt

Author: FabioCanavarro

examples/prometheus_track.rs

@@ -6,9 +6,9 @@ use std::thread::{
 };
 use std::time::Duration;
 
+use axum::Router;
 use axum::extract::State;
 use axum::routing::get;
-use axum::Router;
 use epoch_db::DB;
 use metrics_exporter_prometheus::{
     PrometheusBuilder,

src/bin/server.rs

@@ -4,9 +4,9 @@ use std::path::PathBuf;
 use std::sync::Arc;
 use std::time::Duration;
 
+use epoch_db::DB;
 use epoch_db::server::response_handler;
 use epoch_db::server::utils::init_logger;
-use epoch_db::DB;
 use tokio::net::TcpListener;
 use tokio::spawn;
 use tokio::time::sleep;

src/db/iter.rs

@@ -3,8 +3,8 @@ use std::str::from_utf8;
 use std::sync::Arc;
 
 use crate::{
-    Metadata,
-    DB
+    DB,
+    Metadata
 };
 
 /// This is an iterator struct that represents the Database main iterator

src/db/mod.rs

@@ -14,8 +14,8 @@ use std::io::{
 };
 use std::path::Path;
 use std::str::from_utf8;
-use std::sync::atomic::AtomicBool;
 use std::sync::Arc;
+use std::sync::atomic::AtomicBool;
 use std::thread::{
     self,
     JoinHandle
@@ -28,12 +28,12 @@ use std::time::{
 
 use chrono::Local;
 use errors::TransientError;
+use sled::Config;
 use sled::transaction::{
     ConflictableTransactionError,
     TransactionError,
     Transactional
 };
-use sled::Config;
 use zip::write::SimpleFileOptions;
 use zip::{
     ZipArchive,
@@ -42,8 +42,8 @@ use zip::{
 
 use crate::metrics::Metrics;
 use crate::{
-    Metadata,
-    DB
+    DB,
+    Metadata
 };
 
 impl DB {

src/db/transaction/mod.rs

@@ -16,8 +16,8 @@ use sled::transaction::{
 use crate::db::errors::TransientError;
 use crate::db::transaction::metric_handler::GuardMetricChanged;
 use crate::{
-    Metadata,
-    DB
+    DB,
+    Metadata
 };
 
 pub mod metric_handler;

src/lib.rs

@@ -12,8 +12,8 @@
 //! frequency** and **age** as first-class citizens.
 
 use std::path::PathBuf;
-use std::sync::atomic::AtomicBool;
 use std::sync::Arc;
+use std::sync::atomic::AtomicBool;
 use std::thread::JoinHandle;
 
 use db::errors::TransientError;

src/server/mod.rs

@@ -13,14 +13,15 @@ use tokio::io::{
     BufReader,
     BufWriter
 };
-use tokio::net::tcp::WriteHalf;
 use tokio::net::TcpStream;
+use tokio::net::tcp::WriteHalf;
 use tracing::{
     error,
     info,
     warn
 };
 
+use crate::DB;
 use crate::db::errors::TransientError;
 use crate::metadata::RespValue;
 use crate::server::commands::{
@@ -32,7 +33,6 @@ use crate::server::utils::{
     parse_bulk_string,
     parse_integer
 };
-use crate::DB;
 
 pub static CLIENT_COMMAND_SIZE: u64 = 4096;
 

src/server/utils.rs

@@ -9,8 +9,8 @@ use tokio::io::{
 };
 use tracing::error;
 use tracing_subscriber::{
-    fmt,
-    EnvFilter
+    EnvFilter,
+    fmt
 };
 
 use crate::db::errors::TransientError;

tests/server_parser_test.rs

@@ -1,19 +1,16 @@
 use std::io::Cursor;
 
-use epoch_db::server::{commands::ParsedResponse, parse_command};
+use epoch_db::server::commands::ParsedResponse;
+use epoch_db::server::parse_command;
 use tokio::io::BufReader;
 
-mod server_common;
-
-
-
 #[tokio::test]
-async fn valid_command_test () {
-/*
-    * *2\r\n$3\r\nGET\r\n$3\r\nkey\r\n
-    * *4\r\n$3\r\nSET\r\n$3\r\nkey\r\n$5\r\nvalue\r\n$4\r\n1000\r\n
-    * *3\r\n$3\r\nSET\r\n$3\r\nkey\r\n$0\r\n\r\n
-*/
+async fn valid_command_test() {
+    /*
+     * *2\r\n$3\r\nGET\r\n$3\r\nkey\r\n
+     * *4\r\n$3\r\nSET\r\n$3\r\nkey\r\n$5\r\nvalue\r\n$4\r\n1000\r\n
+     * *3\r\n$3\r\nSET\r\n$3\r\nkey\r\n$0\r\n\r\n
+     */
     let buf = b"*2\r\n$3\r\nGET\r\n$3\r\nkey\r\n";
     let c = Cursor::new(buf);
 
@@ -25,9 +22,8 @@ async fn valid_command_test () {
             command: epoch_db::server::commands::Command::Get,
             key: Some(Vec::from(b"key")),
             value: None,
-            ttl: None, 
+            ttl: None,
             len: 2
         }
     )
-
 }