feat(storage): finish B-II Raft-replicated block backend (items 1, 2, 5, 6 landed; 3 partial; 4, 7 operator-driven)

Cargo.toml

@@ -3,9 +3,13 @@ members = [
 "apps/agent", "apps/guest-agent",
 "apps/manager",
 "apps/installer",
+"apps/raftblk-vhost",
 "crates/nexus-backup",
+"crates/nexus-raft-block",
 "crates/nexus-storage",
 "crates/nexus-types",
+"crates/nqvm-cli",
+"crates/raftblk-vhost",
 ]
 resolver = "2"
 

apps/agent/Cargo.toml

@@ -29,6 +29,8 @@ uuid = { workspace = true }
 futures = { workspace = true }
 libc = "0.2"
 nexus-backup = { path = "../../crates/nexus-backup" }
+nexus-raft-block = { path = "../../crates/nexus-raft-block" }
+openraft = { version = "=0.9.24", features = ["serde"] }
 aws-sdk-s3 = { version = "1", default-features = false, features = ["rustls", "rt-tokio"] }
 aws-credential-types = "1"
 aws-config = { version = "1", default-features = false, features = ["rustls", "rt-tokio"] }

apps/agent/src/features/mod.rs

@@ -5,6 +5,7 @@ use std::sync::Arc;
 pub mod health;
 pub mod inventory;
 pub mod networks;
+pub mod raft_block;
 pub mod storage;
 pub mod tap;
 pub mod vm;
@@ -18,6 +19,10 @@ pub fn router(state: AppState) -> Router {
         .merge(inventory::router())
         .nest("/agent/v1/vms", vm::router().merge(tap::router()))
         .nest("/agent/v1/networks", networks::router())
+        .nest(
+            "/v1/raft_block",
+            raft_block::router(state.raft_block_state.clone()),
+        )
         .nest("/v1/storage", storage::routes::router(storage_state))
         .layer(Extension(state))
 }