refactor(storage): remove Engine abstraction

.github/workflows/ci.yml

@@ -253,7 +253,7 @@ jobs:
         run: make -C tests install-deps
 
       - name: Run integration tests
-        run: make -C tests test-python
+        run: bash tests/run_python_integration.sh
 
   sanitizers:
     name: Sanitizers (${{ matrix.sanitizer }})

CLAUDE.md

@@ -65,9 +65,8 @@ Workspace members under `src/`:
 - `cmd/` — Redis command implementations. Each command implements the `Cmd` trait.
 - `executor/` — Async command executor / task pool.
 - `client/` — Per-connection client state (`argv`, `cmd_name`, `key`, reply buffer, authentication).
-- `storage/` — Multi-instance RocksDB storage, column families, TTL, key encoding, and log index for Raft.
-- `engine/` — `Engine` trait abstraction and RocksDB engine implementation.
-- `raft/` — OpenRaft integration, log store, state machine, snapshot archive, and gRPC services.
+- `storage/` — Multi-instance concrete RocksDB ownership, column families, TTL, key encoding, and log index for Raft.
+- `raft/` — OpenRaft integration, concrete RocksDB log-store ownership, state machine, snapshot archive, and gRPC services.
 - `conf/` — Configuration loading, validation, and sample-config generation.
 - `kstd/` — Utilities, including `LockMgr` for sharded key-level locking.
 - `common/runtime/` — Dual-runtime manager, async message channel between network and storage runtimes, and `StorageServer`.

Cargo.toml

@@ -1,7 +1,6 @@
 [workspace]
 resolver = "2"
 members = [
-	"src/engine",
 	"src/storage",
 	"src/kstd",
 	"src/common/macro",
@@ -75,9 +74,9 @@ uuid = { version = "1.23", features = ["v4", "serde"] }
 openraft = { version = "0.9", features = ["serde", "storage-v2"] }
 proptest = "1.11"
 arc-swap = "1.7"
+windows-sys = { version = "0.61.2", features = ["Win32_Storage_FileSystem"] }
 
 ## workspaces members
-engine = { path = "src/engine" }
 storage = { path = "src/storage" }
 kstd = { path = "src/kstd" }
 common-macro = { path = "src/common/macro" }
@@ -107,4 +106,4 @@ lto = "thin"
 overflow-checks = false
 opt-level = "s"         # defaults to be 3
 incremental = false
-codegen-units = 1
+codegen-units = 1

README.md

@@ -24,10 +24,9 @@ src/server/    → Entry point (main.rs)
 src/net/       → TCP server, connection handling, cluster routing
 src/cmd/       → Command definitions: Cmd trait, CmdMeta, command table
 src/executor/  → Command executor: tokio async task pool
-src/storage/   → Multi-instance RocksDB, column families, TTL
-src/engine/    → Engine trait abstraction over RocksDB
+src/storage/   → Multi-instance RocksDB ownership, column families, TTL
 src/resp/      → RESP protocol: parser, encoder, RespData types
-src/raft/      → Raft consensus: OpenRaft integration, state machine, router
+src/raft/      → Raft consensus: OpenRaft integration, RocksDB log store, state machine, router
 src/conf/      → Configuration: loading, validation, RaftClusterConfig
 src/client/    → Client context: connection state, argv, reply buffer
 src/common/runtime/ → Runtime management: async channel between net & storage

README_CN.md

@@ -24,10 +24,9 @@ src/server/    → 入口 (main.rs)
 src/net/       → TCP 服务、连接管理、集群路由
 src/cmd/       → 命令定义：Cmd trait、CmdMeta、命令表
 src/executor/  → 命令执行器：tokio 异步任务池
-src/storage/   → 多实例 RocksDB、列族、TTL
-src/engine/    → RocksDB 引擎 trait 抽象
+src/storage/   → 多实例 RocksDB 所有权、列族、TTL
 src/resp/      → RESP 协议：解析、编码、RespData 类型
-src/raft/      → Raft 共识：OpenRaft 集成、状态机、路由器
+src/raft/      → Raft 共识：OpenRaft 集成、RocksDB 日志存储、状态机、路由器
 src/conf/      → 配置：加载、校验、集群配置
 src/client/    → 客户端上下文：连接状态、参数、响应缓冲
 src/common/runtime/ → 运行时管理：网络与存储间的异步通道