chore: remove local state-machine-api directory (#18395)

* refactor: migrate state-machine-api to external crate

- Move src/meta/state-machine-api to standalone external crate
- Update all Cargo.toml files to reference external git repository
- Replace crate name from databend_common_meta_state_machine_api to state_machine_api
- Use tagged version v0.1.0 from https://github.com/databendlabs/state-machine-api.git
- Update 28+ Rust files with new import paths
- All compilation and lint checks passing

External crate details:
- Repository: https://github.com/databendlabs/state-machine-api.git
- Tag: v0.1.0
- CI: Passing with GitHub Actions
- Tests: 22 tests passing

* chore: remove local state-machine-api directory

- Directory has been successfully migrated to external crate
- All references now use external git dependency
- Compilation verified to work with external crate only

* chore: fix Cargo.toml fmt

Author: drmingdrmer

Cargo.lock

@@ -105,7 +105,6 @@ members = [
     "src/meta/raft-store",
     "src/meta/semaphore",
     "src/meta/sled-store",
-    "src/meta/state-machine-api",
     "src/meta/stoerr",
     "src/meta/store",
     "src/meta/types",
@@ -156,7 +155,6 @@ databend-common-meta-process = { path = "src/meta/process" }
 databend-common-meta-raft-store = { path = "src/meta/raft-store" }
 databend-common-meta-semaphore = { path = "src/meta/semaphore" }
 databend-common-meta-sled-store = { path = "src/meta/sled-store" }
-databend-common-meta-state-machine-api = { path = "src/meta/state-machine-api" }
 databend-common-meta-stoerr = { path = "src/meta/stoerr" }
 databend-common-meta-store = { path = "src/meta/store" }
 databend-common-meta-types = { path = "src/meta/types" }
@@ -504,6 +502,7 @@ socket2 = "0.5.3"
 span-map = { version = "0.2.0" }
 sqlx = { version = "0.8", features = ["mysql", "runtime-tokio"] }
 state = "0.6.0"
+state-machine-api = { version = "0.1.0" }
 stream-more = "0.1.3"
 strength_reduce = "0.2.4"
 stringslice = "0.2.0"
@@ -666,6 +665,7 @@ openraft = { git = "https://github.com/databendlabs/openraft", tag = "v0.10.0-al
 orc-rust = { git = "https://github.com/datafuse-extras/orc-rust", rev = "d82aa6d" }
 recursive = { git = "https://github.com/datafuse-extras/recursive.git", rev = "6af35a1" }
 sled = { git = "https://github.com/datafuse-extras/sled", tag = "v0.34.7-datafuse.1" }
+state-machine-api = { git = "https://github.com/databendlabs/state-machine-api.git", tag = "v0.1.0" }
 sub-cache = { git = "https://github.com/databendlabs/sub-cache", tag = "v0.2.1" }
 tantivy = { git = "https://github.com/datafuse-extras/tantivy", rev = "7502370" }
 tantivy-common = { git = "https://github.com/datafuse-extras/tantivy", rev = "7502370", package = "tantivy-common" }

Cargo.toml

@@ -11,11 +11,11 @@ edition = { workspace = true }
 [dependencies]
 anyhow = { workspace = true }
 databend-common-meta-kvapi = { workspace = true }
-databend-common-meta-state-machine-api = { workspace = true }
 databend-common-meta-types = { workspace = true }
 display-more = { workspace = true }
 fastrace = { workspace = true }
 log = { workspace = true }
+state-machine-api = { workspace = true }
 tokio = { workspace = true }
 
 [lints]

src/meta/kvapi-test-suite/Cargo.toml

@@ -16,7 +16,6 @@ use std::time::Duration;
 use std::time::SystemTime;
 
 use databend_common_meta_kvapi::kvapi;
-use databend_common_meta_state_machine_api::KVMeta;
 use databend_common_meta_types::protobuf as pb;
 use databend_common_meta_types::protobuf::BooleanExpression;
 use databend_common_meta_types::protobuf::FetchAddU64Response;
@@ -50,6 +49,7 @@ use fastrace::func_name;
 use fastrace::func_path;
 use log::debug;
 use log::info;
+use state_machine_api::KVMeta;
 use tokio::time::sleep;
 
 pub struct TestSuite {}

src/meta/kvapi-test-suite/src/kvapi_test_suite.rs

@@ -19,7 +19,6 @@ databend-common-exception = { workspace = true }
 databend-common-grpc = { workspace = true }
 databend-common-meta-kvapi = { workspace = true }
 databend-common-meta-sled-store = { workspace = true }
-databend-common-meta-state-machine-api = { workspace = true }
 databend-common-meta-stoerr = { workspace = true }
 databend-common-meta-types = { workspace = true }
 databend-common-version = { workspace = true }
@@ -44,6 +43,7 @@ semver = { workspace = true }
 seq-marked = { workspace = true, features = ["seq-marked-serde", "seq-marked-bincode", "seqv-serde"] }
 serde = { workspace = true }
 serde_json = { workspace = true }
+state-machine-api = { workspace = true }
 stream-more = { workspace = true }
 strum = { workspace = true }
 strum_macros = { workspace = true }

src/meta/raft-store/Cargo.toml

@@ -16,7 +16,6 @@ use std::future::ready;
 use std::io;
 use std::time::Duration;
 
-use databend_common_meta_state_machine_api::StateMachineApi;
 use databend_common_meta_types::node::Node;
 use databend_common_meta_types::protobuf as pb;
 use databend_common_meta_types::protobuf::boolean_expression::CombiningOperator;
@@ -61,6 +60,7 @@ use log::info;
 use log::warn;
 use num::FromPrimitive;
 use seq_marked::SeqValue;
+use state_machine_api::StateMachineApi;
 
 use crate::state_machine_api_ext::StateMachineApiExt;
 

src/meta/raft-store/src/applier/mod.rs

@@ -19,8 +19,6 @@ use databend_common_meta_sled_store::sled;
 use databend_common_meta_sled_store::SledKeySpace;
 use databend_common_meta_sled_store::SledOrderedSerde;
 use databend_common_meta_sled_store::SledSerde;
-use databend_common_meta_state_machine_api::ExpireKey;
-use databend_common_meta_state_machine_api::ExpireValue;
 use databend_common_meta_stoerr::MetaStorageError;
 use databend_common_meta_types::node::Node;
 use databend_common_meta_types::raft_types::Entry;
@@ -32,6 +30,8 @@ use databend_common_meta_types::SeqNum;
 use databend_common_meta_types::SeqV;
 use serde::Deserialize;
 use serde::Serialize;
+use state_machine_api::ExpireKey;
+use state_machine_api::ExpireValue;
 
 use crate::ondisk::Header;
 use crate::ondisk::OnDisk;

src/meta/raft-store/src/key_spaces.rs

@@ -17,7 +17,6 @@
 use std::future;
 use std::io;
 
-use databend_common_meta_state_machine_api::ExpireValue;
 use databend_common_meta_types::snapshot_db::DB;
 use databend_common_meta_types::SeqNum;
 use databend_common_meta_types::SeqV;
@@ -26,6 +25,7 @@ use futures_util::TryStreamExt;
 use log::info;
 use map_api::map_api_ro::MapApiRO;
 use map_api::IOResultStream;
+use state_machine_api::ExpireValue;
 
 use crate::key_spaces::SMEntry;
 use crate::leveled_store::db_map_api_ro_impl::MapView;

src/meta/raft-store/src/leveled_store/db_exporter.rs

@@ -14,13 +14,13 @@
 
 //! Test for db_map_api_ro_impl.
 
-use databend_common_meta_state_machine_api::ExpireKey;
-use databend_common_meta_state_machine_api::KVMeta;
-use databend_common_meta_state_machine_api::UserKey;
 use databend_common_meta_types::UpsertKV;
 use futures_util::TryStreamExt;
 use map_api::map_api_ro::MapApiRO;
 use seq_marked::SeqMarked;
+use state_machine_api::ExpireKey;
+use state_machine_api::KVMeta;
+use state_machine_api::UserKey;
 
 use crate::leveled_store::db_builder::DBBuilder;
 use crate::leveled_store::db_map_api_ro_impl::MapView;

src/meta/raft-store/src/leveled_store/db_map_api_ro_test.rs

@@ -20,11 +20,11 @@ use std::sync::atomic::AtomicU64;
 use std::sync::atomic::Ordering;
 use std::sync::Arc;
 
-use databend_common_meta_state_machine_api::ExpireKey;
-use databend_common_meta_state_machine_api::MetaValue;
-use databend_common_meta_state_machine_api::UserKey;
 use map_api::map_api_ro::MapApiRO;
 use seq_marked::SeqMarked;
+use state_machine_api::ExpireKey;
+use state_machine_api::MetaValue;
+use state_machine_api::UserKey;
 
 use crate::leveled_store::level::Level;
 use crate::leveled_store::level_index::LevelIndex;