Fixed code formatting

Hirevo · Jan 18, 2020 · 52fddd4 · 52fddd4
1 parent 8fc0e6e
commit 52fddd4
Show file tree

Hide file tree

Showing 12 changed files with 22 additions and 13 deletions.
diff --git a/persist-daemon/src/server/request/delete.rs b/persist-daemon/src/server/request/delete.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{DeleteRequest, DeleteResponse, Response};

diff --git a/persist-daemon/src/server/request/dump.rs b/persist-daemon/src/server/request/dump.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{DumpRequest, DumpResponse, Response};

diff --git a/persist-daemon/src/server/request/info.rs b/persist-daemon/src/server/request/info.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{InfoRequest, InfoResponse, ProcessInfo, ProcessStatus, Response};

diff --git a/persist-daemon/src/server/request/list.rs b/persist-daemon/src/server/request/list.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{ListRequest, Response};

diff --git a/persist-daemon/src/server/request/restart.rs b/persist-daemon/src/server/request/restart.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{Response, RestartRequest, RestartResponse};

diff --git a/persist-daemon/src/server/request/start.rs b/persist-daemon/src/server/request/start.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::daemon::{self, LOGS_DIR, PIDS_DIR};
 use persist_core::error::Error;

diff --git a/persist-daemon/src/server/request/stop.rs b/persist-daemon/src/server/request/stop.rs
@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use futures::sink::SinkExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::{Response, StopRequest, StopResponse};

diff --git a/persist-daemon/src/server/state.rs b/persist-daemon/src/server/state.rs
@@ -9,13 +9,13 @@ use futures::stream::StreamExt;
 use heim::process::Process;
 use heim::units::information::byte;
 use heim::units::ratio;
-use tokio_util::codec::{FramedRead, FramedWrite, LinesCodec};
 use tokio::fs::OpenOptions;
 use tokio::process::{Child, Command};
 use tokio::sync::Mutex;
+use tokio_util::codec::{FramedRead, FramedWrite, LinesCodec};
 
 use persist_core::error::{Error, PersistError};
-use persist_core::protocol::{ProcessInfo, ProcessSpec, ProcessStatus, ListResponse};
+use persist_core::protocol::{ListResponse, ProcessInfo, ProcessSpec, ProcessStatus};
 
 #[derive(Default)]
 pub struct State {

diff --git a/persist/src/commands/delete.rs b/persist/src/commands/delete.rs
@@ -32,7 +32,10 @@ pub async fn handle(opts: Opts) -> Result<(), Error> {
     let responses = daemon.delete(DeleteRequest { filters }).await?;
     for response in responses {
         if let Some(error) = response.error {
-            let msg = format!("process '{}' could not be deleted: {}", response.name, error);
+            let msg = format!(
+                "process '{}' could not be deleted: {}",
+                response.name, error
+            );
             format::error(msg);
         } else {
             let msg = format!("process '{}' successfully deleted.", response.name);

diff --git a/persist/src/commands/restart.rs b/persist/src/commands/restart.rs
@@ -41,7 +41,10 @@ pub async fn handle(opts: Opts) -> Result<(), Error> {
     let responses = daemon.restart(request).await?;
     for response in responses {
         if let Some(error) = response.error {
-            let msg = format!("process '{}' could not be restarted: {}", response.name, error);
+            let msg = format!(
+                "process '{}' could not be restarted: {}",
+                response.name, error
+            );
             format::error(msg);
         } else {
             let msg = format!("process '{}' successfully restarted.", response.name);

diff --git a/persist/src/commands/stop.rs b/persist/src/commands/stop.rs
@@ -33,7 +33,10 @@ pub async fn handle(opts: Opts) -> Result<(), Error> {
 
     for response in responses {
         if let Some(error) = response.error {
-            let msg = format!("process '{}' could not be stopped: {}", response.name, error);
+            let msg = format!(
+                "process '{}' could not be stopped: {}",
+                response.name, error
+            );
             format::error(msg);
         } else {
             let msg = format!("process '{}' successfully stopped.", response.name);

diff --git a/persist/src/daemon/client.rs b/persist/src/daemon/client.rs
@@ -2,8 +2,8 @@ use std::path::Path;
 
 use futures::sink::SinkExt;
 use futures::stream::StreamExt;
-use tokio_util::codec::{Framed, LinesCodec};
 use tokio::net::UnixStream;
+use tokio_util::codec::{Framed, LinesCodec};
 
 use persist_core::error::Error;
 use persist_core::protocol::*;