fix: clippy

Author: v0y4g3r

Cargo.lock

@@ -367,7 +367,7 @@ pub struct TableEntryValue {
 
 #[cfg(test)]
 mod tests {
-    use log_store::fs::noop::NoopLogStore;
+    use log_store::NoopLogStore;
     use mito::config::EngineConfig;
     use mito::engine::MitoEngine;
     use object_store::ObjectStore;

src/catalog/src/system.rs

@@ -21,8 +21,8 @@ use catalog::remote::MetaKvBackend;
 use catalog::CatalogManagerRef;
 use common_grpc::channel_manager::{ChannelConfig, ChannelManager};
 use common_telemetry::logging::info;
-use log_store::fs::config::LogConfig;
-use log_store::fs::log::LocalFileLogStore;
+use log_store::raft_engine::log_store::RaftEngineLogstore;
+use log_store::LogConfig;
 use meta_client::client::{MetaClient, MetaClientBuilder};
 use meta_client::MetaClientOpts;
 use mito::config::EngineConfig as TableEngineConfig;
@@ -53,7 +53,7 @@ mod grpc;
 mod script;
 mod sql;
 
-pub(crate) type DefaultEngine = MitoEngine<EngineImpl<LocalFileLogStore>>;
+pub(crate) type DefaultEngine = MitoEngine<EngineImpl<RaftEngineLogstore>>;
 
 // An abstraction to read/write services.
 pub struct Instance {
@@ -63,7 +63,7 @@ pub struct Instance {
     pub(crate) script_executor: ScriptExecutor,
     pub(crate) table_id_provider: Option<TableIdProviderRef>,
     pub(crate) heartbeat_task: Option<HeartbeatTask>,
-    pub(crate) logstore: Arc<LocalFileLogStore>,
+    pub(crate) logstore: Arc<RaftEngineLogstore>,
 }
 
 pub type InstanceRef = Arc<Instance>;
@@ -278,7 +278,7 @@ async fn new_metasrv_client(node_id: u64, meta_config: &MetaClientOpts) -> Resul
 
 pub(crate) async fn create_local_file_log_store(
     path: impl AsRef<str>,
-) -> Result<LocalFileLogStore> {
+) -> Result<RaftEngineLogstore> {
     let path = path.as_ref();
     // create WAL directory
     fs::create_dir_all(path::Path::new(path)).context(error::CreateDirSnafu { dir: path })?;
@@ -290,9 +290,6 @@ pub(crate) async fn create_local_file_log_store(
         ..Default::default()
     };
 
-    let log_store = LocalFileLogStore::open(&log_config)
-        .await
-        .context(error::OpenLogStoreSnafu)?;
-
-    Ok(log_store)
+    let logstore = RaftEngineLogstore::new(log_config);
+    Ok(logstore)
 }

src/datanode/src/instance.rs

@@ -125,7 +125,7 @@ mod tests {
     use datatypes::prelude::ConcreteDataType;
     use datatypes::schema::{ColumnSchema, SchemaBuilder, SchemaRef};
     use datatypes::value::Value;
-    use log_store::fs::noop::NoopLogStore;
+    use log_store::NoopLogStore;
     use mito::config::EngineConfig as TableEngineConfig;
     use mito::engine::MitoEngine;
     use object_store::services::fs::Builder;

src/datanode/src/sql.rs

@@ -17,8 +17,8 @@ use protobuf_build::Builder;
 fn main() {
     let base = std::env::var("CARGO_MANIFEST_DIR").unwrap_or_else(|_| ".".to_string());
     Builder::new()
-        .search_dir_for_protos(&format!("{}/proto", base))
-        .includes(&[format!("{}/include", base), format!("{}/proto", base)])
+        .search_dir_for_protos(&format!("{base}/proto"))
+        .includes(&[format!("{base}/include"), format!("{base}/proto")])
         .include_google_protos()
         .generate()
 }