refactor(workspace): 主包迁入 src/function-stream 并集中 workspace 元数据

- 根 Cargo.toml 改为纯 workspace，主程序与库移至 src/function-stream
- 新增 [workspace.package] 统一 version / edition，成员 crate 使用 *.workspace = true
- Makefile：VERSION 从根 Cargo.toml 读取，构建显式 -p function-stream，lite 使用 OPTIMIZE_FLAGS
- wasm_host bindgen WIT 路径改为 ../../wit，以适配子目录中的 package manifest
- 移除根 src 下旧入口与 runtime/storage 模块，streaming/wasm 等 crate 路径与导入同步调整
- examples-validator 与全仓 edition 对齐为 2024

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: luoluoyuyu

Cargo.lock

@@ -1,6 +1,6 @@
 [workspace]
 members = [
-    ".",
+    "src/function-stream",
     "protocol",
     "cli/cli",
     "src/catalog",
@@ -17,91 +17,10 @@ members = [
     "src/streaming_planner",
     "src/wasm_runtime",
 ]
+resolver = "2"
+default-members = ["src/function-stream"]
 
-[package]
-name = "function-stream"
+# Shared crate metadata for workspace members (`version.workspace = true`, etc.).
+[workspace.package]
 version = "0.6.0"
 edition = "2024"
-
-[lib]
-name = "function_stream"
-path = "src/lib.rs"
-
-[[bin]]
-name = "function-stream"
-path = "src/main.rs"
-
-
-[dependencies]
-tokio = { version = "1.0", features = ["macros", "rt-multi-thread", "sync", "time", "net", "signal"] }
-serde = { version = "1.0", features = ["derive"] }
-serde_yaml = "0.9"
-serde_json = "1.0"
-uuid = { version = "1.0", features = ["v4", "v7"] }
-log = "0.4"
-tracing = "0.1"
-tracing-subscriber = { version = "0.3", features = ["env-filter"] }
-tracing-appender = "0.2"
-anyhow = "1.0"
-thiserror = "2"
-tonic = { version = "0.12", features = ["default"] }
-async-trait = "0.1"
-num_cpus = "1.0"
-protocol = { path = "./protocol" }
-function-stream-config = { path = "src/config" }
-function-stream-logger = { path = "src/logger" }
-function-stream-runtime-common = { path = "src/runtime_common" }
-function-stream-streaming-planner = { path = "src/streaming_planner" }
-prost = "0.13"
-rdkafka = { version = "0.38", features = ["cmake-build", "ssl", "gssapi", "curl"] }
-crossbeam-channel = "0.5"
-wasmtime = { version = "41.0.3", features = ["component-model", "async"] }
-base64 = "0.22"
-wasmtime-wasi = "41.0.3"
-rocksdb = { version = "0.21", features = ["multi-threaded-cf", "lz4"] }
-bincode = { version = "2", features = ["serde"] }
-chrono = "0.4"
-tokio-stream = "0.1.18"
-lru = "0.12"
-parking_lot = "0.12"
-arrow = { version = "55", default-features = false }
-arrow-array = "55"
-arrow-ipc = "55"
-arrow-schema = { version = "55", features = ["serde"] }
-parquet = "55"
-object_store = { version = "0.12.5", features = ["aws"] }
-bytes = "1"
-futures = "0.3"
-serde_json_path = "0.7"
-xxhash-rust = { version = "0.8", features = ["xxh3"] }
-proctitle = "0.1"
-unicase = "2.7"
-petgraph = "0.7"
-rand = { version = "0.8", features = ["small_rng"] }
-itertools = "0.14"
-strum = { version = "0.26", features = ["derive"] }
-
-arrow-json = {version = '55.2.0'}
-apache-avro = "0.21"
-datafusion = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-datafusion-common = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-datafusion-execution = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-datafusion-expr = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-datafusion-physical-expr = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-datafusion-proto = {git = 'https://github.com/FunctionStream/datafusion', branch = '48.0.1/fs'}
-
-sqlparser = { git = "https://github.com/FunctionStream/sqlparser-rs", branch = "0.58.0/fs" }
-
-ahash = "0.8"
-governor = "0.8.0"
-lance = { version = "4.0.0", default-features = false, features = ["aws"] }
-arrow-array-lance = { package = "arrow-array", version = "57.3.0" }
-arrow-ipc-lance = { package = "arrow-ipc", version = "57.3.0" }
-
-[features]
-default = ["incremental-cache", "python"]
-incremental-cache = ["wasmtime/incremental-cache"]
-python = []
-
-[dev-dependencies]
-tempfile = "3.27.0"

Cargo.toml

@@ -10,6 +10,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 APP_NAME    := function-stream
+# Version from root `[workspace.package]` (single source of truth).
 VERSION     := $(shell grep '^version' Cargo.toml | head -1 | awk -F '"' '{print $$2}')
 DATE        := $(shell date -u +"%Y-%m-%dT%H:%M:%SZ")
 
@@ -106,6 +107,7 @@ build: .check-env .ensure-target .build-wasm
 	@RUSTFLAGS="$(OPTIMIZE_FLAGS)" \
 	cargo build --release \
 		--target $(TRIPLE) \
+		-p $(APP_NAME) \
 		--features python \
 		--quiet
 	$(call log,BUILD,CLI)
@@ -118,14 +120,15 @@ build: .check-env .ensure-target .build-wasm
 
 build-lite: .check-env .ensure-target
 	$(call log,BUILD,Rust Lite [$(OS_NAME) / $(TRIPLE)])
-	@RUSTFLAGS="$(INDUSTRIAL_RUSTFLAGS)" \
+	@RUSTFLAGS="$(OPTIMIZE_FLAGS)" \
 	cargo build --release \
 	   --target $(TRIPLE) \
+	   -p $(APP_NAME) \
 	   --no-default-features \
 	   --features incremental-cache \
 	   --quiet
 	$(call log,BUILD,CLI for dist)
-	@RUSTFLAGS="$(INDUSTRIAL_RUSTFLAGS)" \
+	@RUSTFLAGS="$(OPTIMIZE_FLAGS)" \
 	cargo build --release \
 	   --target $(TRIPLE) \
 	   -p function-stream-cli \

Makefile

@@ -1,7 +1,7 @@
 [package]
 name = "function-stream-cli"
-version = "0.1.0"
-edition = "2021"
+version.workspace = true
+edition.workspace = true
 
 [[bin]]
 name = "cli"

cli/cli/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "examples-validator"
 version = "0.1.0"
-edition = "2021"
+edition = "2024"
 
 [workspace]
 

examples/examples-validator/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "protocol"
-version = "0.1.0"
-edition = "2024"
+version.workspace = true
+edition.workspace = true
 description = "Protocol Buffers protocol definitions for function stream"
 license = "MIT OR Apache-2.0"
 repository = "https://github.com/your-username/rust-function-stream"

protocol/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "function-stream-catalog"
-version = "0.6.0"
-edition = "2024"
+version.workspace = true
+edition.workspace = true
 
 [lib]
 name = "function_stream_catalog"

src/catalog/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "function-stream-catalog-storage"
-version = "0.6.0"
-edition = "2024"
+version.workspace = true
+edition.workspace = true
 
 [lib]
 name = "function_stream_catalog_storage"

src/catalog_storage/Cargo.toml

@@ -1,7 +1,7 @@
 //! Persistent catalog storage implementations.
 //!
 //! The stream catalog manager and task persistence (`stream_catalog/`, `task/`) live in this
-//! package and are compiled as part of `function-stream` via `#[path]` in `src/storage.rs`.
+//! package and are compiled as part of `function-stream` via `#[path]` in `src/lib.rs` / `src/main.rs`.
 
 pub mod memory;
 pub mod rocksdb;

src/catalog_storage/src/lib.rs

@@ -627,7 +627,7 @@ pub fn restore_global_catalog_from_store() {
 }
 
 pub fn restore_streaming_jobs_from_store() {
-    use crate::runtime::streaming::job::JobManager;
+    use crate::streaming::job::JobManager;
 
     let Some(catalog) = CatalogManager::try_global() else {
         warn!("CatalogManager not available; skipping streaming job restore");
@@ -742,7 +742,7 @@ mod tests {
     use crate::sql::schema::column_descriptor::ColumnDescriptor;
     use crate::sql::schema::table::CatalogEntity;
     use crate::sql::schema::temporal_pipeline_config::TemporalPipelineConfig;
-    use crate::storage::stream_catalog::InMemoryMetaStore;
+    use crate::stream_catalog::InMemoryMetaStore;
 
     use super::CatalogManager;