feat(store)!: extract nexus-wake + nexus-inmemory — tokio out of nexus-store (#300)

Cargo.toml

@@ -3,12 +3,14 @@ resolver = "2"
 members = [
     "crates/nexus",
     "crates/nexus-fjall",
+    "crates/nexus-inmemory",
     "crates/nexus-macros",
     "crates/nexus-macros/tests/cross_crate_test",
     "crates/nexus-nostd-smoketest",
     "crates/nexus-postgres",
     "crates/nexus-store",
     "crates/nexus-store-testing",
+    "crates/nexus-wake",
     "crates/workspace-hack",
     "examples/closing-the-books",
     "examples/fjall-end-to-end",

crates/nexus-fjall/Cargo.toml

@@ -24,6 +24,7 @@ fjall = { workspace = true }
 futures.workspace = true
 nexus = { version = "0.1.0", path = "../nexus" }
 nexus-store = { version = "0.1.0", path = "../nexus-store", features = ["subscription"] }
+nexus-wake = { version = "0.1.0", path = "../nexus-wake" }
 thiserror = { workspace = true, features = ["std"] }
 tokio = { workspace = true, features = ["sync"] }
 workspace-hack = { version = "0.1", path = "../workspace-hack" }

crates/nexus-fjall/src/builder.rs

@@ -4,7 +4,7 @@ use crate::partition::projection_defaults;
 use crate::partition::{AllIndex, KeyspaceConfig, Partitions, point_read_defaults, scan_defaults};
 use crate::store::FjallStore;
 use fjall::KeyspaceCreateOptions;
-use nexus_store::notify::StreamNotifiers;
+use nexus_wake::StreamNotifiers;
 use std::path::{Path, PathBuf};
 
 /// Builder for [`FjallStore`].

crates/nexus-fjall/src/error.rs

@@ -71,11 +71,11 @@ pub enum FjallError {
 
     /// Failed to register a per-stream subscription wake handle.
     ///
-    /// Surfaces [`NotifyError`](nexus_store::notify::NotifyError) from the
+    /// Surfaces [`NotifyError`](nexus_wake::NotifyError) from the
     /// wake registry — in practice only the unreachable subscriber-count
     /// overflow.
     #[error("subscription wake registration failed")]
-    Subscription(#[from] nexus_store::notify::NotifyError),
+    Subscription(#[from] nexus_wake::NotifyError),
 }
 
 #[cfg(test)]

crates/nexus-fjall/src/store.rs

@@ -9,9 +9,9 @@ use nexus::{ErrorId, Version};
 use nexus_store::PendingEnvelope;
 use nexus_store::StreamKey;
 use nexus_store::error::AppendError;
-use nexus_store::notify::{NotifyError, StreamNotifiers, WakeReg};
 use nexus_store::store::RawEventStore;
 use nexus_store::wake::WakeSource;
+use nexus_wake::{NotifyError, StreamNotifiers, WakeReg};
 use std::path::Path;
 use std::sync::Arc;
 

crates/nexus-inmemory/Cargo.toml

@@ -0,0 +1,34 @@
+[package]
+name = "nexus-inmemory"
+version.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+license.workspace = true
+authors.workspace = true
+repository.workspace = true
+description = "In-memory event-store adapter for the Nexus event-sourcing framework"
+readme = "../../README.md"
+keywords = ["event-sourcing", "event-store", "in-memory", "testing"]
+categories = ["data-structures", "development-tools::testing"]
+
+[features]
+export = ["nexus-store/export"]
+import = ["nexus-store/import"]
+
+[dependencies]
+bytes = { workspace = true }
+futures = { workspace = true }
+nexus = { version = "0.1.0", path = "../nexus" }
+nexus-store = { version = "0.1.0", path = "../nexus-store", features = ["subscription"] }
+nexus-wake = { version = "0.1.0", path = "../nexus-wake" }
+thiserror = { workspace = true, features = ["std"] }
+tokio = { workspace = true, features = ["sync"] }
+workspace-hack = { version = "0.1", path = "../workspace-hack" }
+
+[dev-dependencies]
+nexus-store-testing = { version = "0.1.0", path = "../nexus-store-testing" }
+proptest = { workspace = true }
+tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
+
+[lints]
+workspace = true