refactor(meta): separate stream graph building into modules & add uni…

…t tests for scheduler (#7807) There are no substantial changes except for the unit test for the new scheduler. Approved-By: yezizp2012
risingwavelabs · Feb 9, 2023 · e4f2d2f · e4f2d2f
1 parent 42f37b5
commit e4f2d2f
Show file tree

Hide file tree

Showing 11 changed files with 1,809 additions and 1,594 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/meta/Cargo.toml b/src/meta/Cargo.toml
@@ -20,6 +20,7 @@ clap = { version = "3", features = ["derive", "env"] }
 crc32fast = "1"
 crepe = "0.1"
 derivative = "2"
+easy-ext = "1"
 either = "1"
 enum-as-inner = "0.5"
 etcd-client = { version = "0.2", package = "madsim-etcd-client" }

diff --git a/src/meta/src/stream/mod.rs b/src/meta/src/stream/mod.rs
@@ -13,7 +13,6 @@
 // limitations under the License.
 
 mod scale;
-mod scheduler;
 mod source_manager;
 mod stream_graph;
 mod stream_manager;
@@ -22,7 +21,6 @@ mod test_fragmenter;
 mod test_scale;
 
 pub use scale::*;
-pub use scheduler::*;
 pub use source_manager::*;
 pub use stream_graph::*;
 pub use stream_manager::*;
diff --git a/src/meta/src/stream/scheduler.rs b/src/meta/src/stream/scheduler.rs