refactor: index

Signed-off-by: bsbds <69835502+bsbds@users.noreply.github.com>
xline-kv · Jun 21, 2024 · 06ccbf3 · 06ccbf3
1 parent bbf0739
commit 06ccbf3
Show file tree

Hide file tree

Showing 6 changed files with 482 additions and 222 deletions.
diff --git a/crates/xline/src/server/command.rs b/crates/xline/src/server/command.rs
@@ -353,10 +353,7 @@ impl CurpCommandExecutor<Command> for CommandExecutor {
             }
         };
         ops.append(&mut wr_ops);
-        let key_revisions = self.db.flush_ops(ops)?;
-        if !key_revisions.is_empty() {
-            self.kv_storage.insert_index(key_revisions);
-        }
+        let _key_revisions = self.db.flush_ops(ops)?;
         self.lease_storage.mark_lease_synced(wrapper);
         if !quota_enough {
             if let Some(alarmer) = self.alarmer.read().clone() {

diff --git a/crates/xline/src/server/watch_server.rs b/crates/xline/src/server/watch_server.rs
@@ -456,8 +456,7 @@ mod test {
             ..Default::default()
         });
         let (_sync_res, ops) = store.after_sync(&req, revision).await.unwrap();
-        let key_revisions = db.flush_ops(ops).unwrap();
-        store.insert_index(key_revisions);
+        let _key_revisions = db.flush_ops(ops).unwrap();
     }
 
     #[tokio::test]

diff --git a/crates/xline/src/storage/compact/mod.rs b/crates/xline/src/storage/compact/mod.rs
@@ -12,10 +12,7 @@ use utils::{
 };
 use xlineapi::{command::Command, execute_error::ExecuteError, RequestWrapper};
 
-use super::{
-    index::{Index, IndexOperate},
-    KvStore,
-};
+use super::{index::Index, KvStore};
 use crate::{revision_number::RevisionNumberGenerator, rpc::CompactionRequest};
 
 /// mod revision compactor;