Add cargo fmt + clippy Github Action

.github/workflows/clippy-fmt.yml

@@ -0,0 +1,23 @@
+on: [push, pull_request]
+name: Clippy & Fmt
+jobs:
+  clippy:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v1
+      - uses: actions-rs/toolchain@v1
+        with:
+            toolchain: stable
+            components: clippy
+      - name: Cargo Clippy Check 
+        uses: actions-rs/clippy@master
+        with:
+          args: --all-features --all-targets -- -D warnings
+  fmt:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v1
+      - name: Cargo Fmt Check
+        uses: icepuma/rust-action@master
+        with:
+          args: cargo fmt --all -- --check

commit_log/src/lib.rs

@@ -99,10 +99,10 @@ impl CommitLog {
         let segments = vec![Segment::new(path.clone(), 0, segment_size, index_size)?];
 
         Ok(Self {
-            path: path,
-            segments: segments,
-            segment_size: segment_size,
-            index_size: index_size,
+            path,
+            segments,
+            segment_size,
+            index_size,
             current_segment: 0,
         })
     }
@@ -146,7 +146,7 @@ impl CommitLog {
     }
 
     pub fn read(&mut self, position: &Position) -> Result<Record, Error> {
-        return self.read_after(position, 0);
+        self.read_after(position, 0)
     }
 
     fn rotate_segment(&mut self) -> Result<(), Error> {

commit_log/src/reader.rs

@@ -25,7 +25,7 @@ impl<'a> Reader<'a> {
         let segment_index = record.segment_index;
         let total_segments = self.commit_log.segments.len();
         if segment_index >= total_segments {
-            return Err(Error::InvalidPosition);
+            Err(Error::InvalidPosition)
         } else {
             let segment = &self.commit_log.segments[segment_index];
             let buf = segment.read_at(record.current_offset)?;

commit_log/src/segment/index.rs

@@ -8,6 +8,7 @@ use std::path::PathBuf;
 use std::str::from_utf8_unchecked;
 
 use derive_more::From;
+use std::fmt;
 
 #[derive(Debug, From)]
 pub enum Error {
@@ -156,10 +157,11 @@ impl Entry {
     pub fn new(offset: usize, size: usize) -> Self {
         Self { offset, size }
     }
+}
 
-    /// Convert an entry to string
-    pub fn to_string(&self) -> String {
-        format!("{:010}{:010}", self.offset, self.size)
+impl fmt::Display for Entry {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        write!(f, "{:010}{:010}", self.offset, self.size)
     }
 }
 

commit_log/src/segment/log.rs

@@ -76,7 +76,7 @@ impl Log {
             base_offset,
             offset,
             max_size,
-            mmap: mmap,
+            mmap,
         })
     }
 

commit_log/src/segment/mod.rs

@@ -55,8 +55,8 @@ impl Segment {
     ) -> Result<Self, Error> {
         Ok(Self {
             log: Log::new(path.clone(), offset, max_log_size)?,
-            index: Index::new(path.clone(), offset, max_index_size)?,
-            offset: offset,
+            index: Index::new(path, offset, max_index_size)?,
+            offset,
         })
     }