refactor(meta): splits source_manager into smaller mods

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Jan 8, 2025 · 00d90c8 · 00d90c8
1 parent 1bc6bea
commit 00d90c8
Show file tree

Hide file tree

Showing 4 changed files with 1,159 additions and 1,126 deletions.
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
@@ -75,7 +75,7 @@ use crate::manager::{
 };
 use crate::model::{StreamContext, StreamJobFragments, TableParallelism};
 use crate::stream::{
-    create_source_worker_handle, validate_sink, ActorGraphBuildResult, ActorGraphBuilder,
+    create_source_worker, validate_sink, ActorGraphBuildResult, ActorGraphBuilder,
     CompleteStreamFragmentGraph, CreateStreamingJobContext, CreateStreamingJobOption,
     GlobalStreamManagerRef, ReplaceStreamJobContext, SourceChange, SourceManagerRef,
     StreamFragmentGraph,
@@ -441,7 +441,7 @@ impl DdlController {
 
     /// Shared source is handled in [`Self::create_streaming_job`]
     async fn create_non_shared_source(&self, source: Source) -> MetaResult<NotificationVersion> {
-        let handle = create_source_worker_handle(&source, self.source_manager.metrics.clone())
+        let handle = create_source_worker(&source, self.source_manager.metrics.clone())
             .await
             .context("failed to create source worker")?;