feat: compaction trigger

src/compaction/mod.rs

@@ -27,10 +27,11 @@ use crate::{
     },
     DbOption, Schema,
 };
+use crate::inmem::mutable::Mutable;
 
 #[derive(Debug)]
 pub(crate) enum CompactTask {
-    Flush,
+    Freeze,
 }
 
 pub(crate) struct Compactor<R, FP>
@@ -67,6 +68,14 @@ where
     ) -> Result<(), CompactionError<R>> {
         let mut guard = self.schema.write().await;
 
+        if guard.mutable.is_empty() {
+            println!("WWWWWW");
+            return Ok(())
+        }
+        let mutable = mem::replace(&mut guard.mutable, Mutable::new(&self.option).await?);
+        let (file_id, immutable) = mutable.to_immutable().await?;
+
+        guard.immutables.push_front((file_id, immutable));
         if guard.immutables.len() > self.option.immutable_chunk_num {
             let excess = guard.immutables.split_off(self.option.immutable_chunk_num);
 

src/executor.rs

@@ -16,6 +16,7 @@ pub mod tokio {
 
     use super::Executor;
 
+    #[derive(Debug)]
     pub struct TokioExecutor {
         handle: Handle,
     }

src/inmem/mutable.rs

@@ -143,6 +143,10 @@ where
         self.data.range((lower, upper))
     }
 
+    pub(crate) fn is_empty(&self) -> bool {
+        self.data.is_empty()
+    }
+
     pub(crate) fn check_conflict(&self, key: &R::Key, ts: Timestamp) -> bool {
         self.data
             .range::<TimestampedRef<<R as Record>::Key>, _>((