Distributed in-memory key/value store for mapreduce

Cargo.toml

@@ -1,10 +1,5 @@
 [workspace]
-members = [
-  "crates/core",
-  "crates/optics",
-  "crates/kuchiki",
-  "crates/zimba",
-]
+members = ["crates/core", "crates/optics", "crates/kuchiki", "crates/zimba"]
 resolver = "2"
 
 [profile.release]
@@ -16,51 +11,52 @@ debug = true
 
 [workspace.dependencies]
 aes-gcm = "0.10.2"
-anyhow = {version = "1.0.72", features = ["backtrace"]}
+anyhow = { version = "1.0.72", features = ["backtrace"] }
 async-channel = "1.8.0"
 async-stream = "0.3.3"
 axum = "0.7.2"
-axum-extra = {version = "0.9.0"}
+axum-extra = { version = "0.9.0" }
 axum-macros = "0.4.0"
 base64 = "0.21.4"
 bincode = "1.3.3"
 bindgen = "0.69.2"
 bitvec = "1.0.1"
 bytecount = "0.6.7"
-bytemuck = {version = "1.13.1", features = ["derive"]}
+bytemuck = { version = "1.13.1", features = ["derive"] }
 byteorder = "1.4.3"
 bzip2 = "0.4.4"
 candle-core = "0.3.3"
 candle-nn = "0.3.3"
+openraft = { version = "0.9.1", features = ["storage-v2", "serde"] }
 candle-transformers = "0.3.3"
-cc = {version = "1", features = ["parallel"]}
+cc = { version = "1", features = ["parallel"] }
 chardetng = "0.1.17"
 chitchat = "0.5.0"
-chrono = {version = "0.4.23", features = ["serde"]}
-clap = {version = "4.4.6", features = ["derive"]}
+chrono = { version = "0.4.23", features = ["serde"] }
+clap = { version = "4.4.6", features = ["derive"] }
 cmake = "0.1"
 criterion = "0.5.1"
 crossbeam-channel = "0.5.6"
 csv = "1.1.6"
-dashmap = {version = "5.4.0", features = ["rayon"]}
+dashmap = { version = "5.4.0", features = ["rayon"] }
 encoding_rs = "0.8.31"
 eventsource-stream = "0.2.3"
 fend-core = "1.2.2"
 flate2 = "1.0.28"
 fnv = "1.0.3"
-fst = {version = "0.4.7", features = ["levenshtein"]}
+fst = { version = "0.4.7", features = ["levenshtein"] }
 futures = "0.3.21"
-half = {version = "2.2.1", features = ["serde"]}
-hashbrown = {version = "0.14.0", features = ["serde"]}
+half = { version = "2.2.1", features = ["serde"] }
+hashbrown = { version = "0.14.0", features = ["serde"] }
 http = "1.0.0"
 image = "0.24.3"
-indicatif = {version = "0.17.7", features = ["rayon"]}
+indicatif = { version = "0.17.7", features = ["rayon"] }
 insta = "1.31"
 itertools = "0.11.0"
-lalrpop = {version = "0.20.0", features = ["lexer"]}
-lalrpop-util = {version = "0.20.0", features = ["lexer"]}
+lalrpop = { version = "0.20.0", features = ["lexer"] }
+lalrpop-util = { version = "0.20.0", features = ["lexer"] }
 libc = "0.2.142"
-log = {version = "0.4", features = ["release_max_level_info"]}
+log = { version = "0.4", features = ["release_max_level_info"] }
 logos = "0.13.0"
 lz-str = "0.2.1"
 lz4_flex = "0.11.1"
@@ -80,41 +76,42 @@ quick-xml = "0.30.0"
 rand = "0.8.5"
 rayon = "1.5.3"
 regex = "1.6.0"
-reqwest = {version = "0.11.16", features = ["blocking", "stream", "json"]}
+reqwest = { version = "0.11.16", features = ["blocking", "stream", "json"] }
 ring = "0.17.3"
 rio_api = "0.8.4"
 rio_turtle = "0.8.4"
 robotstxt-with-cache = "0.4.0"
-rocksdb = {version = "0.21.0", features = ["default", "jemalloc", "io-uring"]}
-rusqlite = {version = "0.29.0", features = [
-  "bundled",
-  "modern-full",
-  "buildtime_bindgen",
-]}
-rust-s3 = {version = "0.33.0", features = ["blocking", "tokio"]}
+rocksdb = { version = "0.21.0", features = ["default", "jemalloc", "io-uring"] }
+rusqlite = { version = "0.29.0", features = [
+    "bundled",
+    "modern-full",
+    "buildtime_bindgen",
+] }
+rust-s3 = { version = "0.33.0", features = ["blocking", "tokio"] }
 rust-stemmers = "1.2.0"
 safetensors = "0.3.1"
-scylla = {version = "0.12.0", features = ["chrono"]}
-serde = {version = "1.0.137", features = ["rc", "derive"]}
+scylla = { version = "0.12.0", features = ["chrono"] }
+serde = { version = "1.0.137", features = ["rc", "derive"] }
 serde_json = "1.0.81"
 serde_urlencoded = "0.7.1"
-tantivy = {git = "https://github.com/quickwit-oss/tantivy", rev = "182f58cea"}
+tantivy = { git = "https://github.com/quickwit-oss/tantivy", rev = "182f58cea" }
 thiserror = "1.0.31"
 tikv-jemallocator = "0.5"
 tokenizers = "0.13.2"
-tokio = {version = "1.23.1", features = ["full"]}
+tokio = { version = "1.23.1", features = ["full"] }
 tokio-stream = "0.1.11"
 toml = "0.8.2"
-tower-http = {version = "0.5.0", features = ["compression-gzip", "cors"]}
-tracing = {version = "0.1.34", features = ["release_max_level_info"]}
-tracing-subscriber = {version = "0.3.11", features = ["env-filter"]}
-url = {version = "2.4.0", features = ["serde"]}
+tower-http = { version = "0.5.0", features = ["compression-gzip", "cors"] }
+tracing = { version = "0.1.34", features = ["release_max_level_info"] }
+tracing-subscriber = { version = "0.3.11", features = ["env-filter"] }
+url = { version = "2.4.0", features = ["serde"] }
 urlencoding = "2.1.2"
-utoipa = {version = "4.0.0", features = ["axum_extras"]}
-utoipa-swagger-ui = {version = "5.0.0", features = ["axum"]}
+utoipa = { version = "4.0.0", features = ["axum_extras"] }
+utoipa-swagger-ui = { version = "5.0.0", features = ["axum"] }
 uuid = "1.1.2"
-whatlang = {version = "0.16.0", features = ["serde"]}
+whatlang = { version = "0.16.0", features = ["serde"] }
 zstd = "0.13"
+tracing-test = "0.2.4"
 
 [profile.test.package]
 flate2.opt-level = 3