[LogServer] Initial implementation for store path

Cargo.toml

@@ -78,6 +78,7 @@ async-channel = "2.1.1"
 async-trait = "0.1.73"
 axum = { version = "0.7.5", default-features = false }
 base64 = "0.22"
+bitflags = { version = "2.6.0" }
 bytes = { version = "1.7", features = ["serde"] }
 bytes-utils = "0.1.3"
 bytestring = { version = "1.2", features = ["serde"] }

crates/core/src/task_center_types.rs

@@ -100,6 +100,7 @@ pub enum TaskKind {
     #[strum(props(OnCancel = "abort"))]
     Watchdog,
     NetworkMessageHandler,
+    LogletWriter,
 }
 
 impl TaskKind {

crates/log-server/Cargo.toml

@@ -19,8 +19,11 @@ restate-rocksdb = { workspace = true }
 restate-types = { workspace = true, features = ["replicated-loglet"] }
 
 anyhow = { workspace = true }
+bitflags = { workspace = true }
 bytes = { workspace = true }
+chrono = { workspace = true }
 codederror = { workspace = true }
+dashmap = { workspace = true }
 derive_more = { workspace = true }
 futures = { workspace = true }
 metrics = { workspace = true }
@@ -36,6 +39,7 @@ tokio = { workspace = true }
 tokio-stream = { workspace = true, features = ["sync"] }
 tokio-util = { workspace = true }
 tracing = { workspace = true }
+xxhash-rust = { workspace = true, features = ["xxh3"] }
 
 
 [dev-dependencies]

crates/log-server/src/lib.rs

@@ -9,6 +9,7 @@
 // by the Apache License, Version 2.0.
 
 mod error;
+mod loglet_worker;
 mod logstore;
 mod metadata;
 mod metric_definitions;
@@ -18,3 +19,14 @@ mod service;
 
 pub use error::LogServerBuildError;
 pub use service::LogServerService;
+
+#[cfg(test)]
+pub(crate) fn setup_panic_handler() {
+    // Make sure that panics exits the process.
+    let orig_hook = std::panic::take_hook();
+    std::panic::set_hook(Box::new(move |panic_info| {
+        // invoke the default handler and exit the process
+        orig_hook(panic_info);
+        std::process::exit(1);
+    }));
+}