private mod pipeline::pipeline_version

SpringQL · Jun 10, 2022 · 80bbd0f · 80bbd0f
1 parent aa32b81
commit 80bbd0f
Show file tree

Hide file tree

Showing 8 changed files with 15 additions and 16 deletions.
diff --git a/springql-core/src/pipeline.rs b/springql-core/src/pipeline.rs
@@ -6,7 +6,7 @@ mod field;
 mod name;
 mod option;
 mod pipeline_graph;
-pub(crate) mod pipeline_version;
+mod pipeline_version;
 pub(crate) mod pump_model;
 pub(crate) mod relation;
 pub(crate) mod sink_writer_model;
@@ -25,6 +25,7 @@ pub(crate) use option::{
     InMemoryQueueOptions, NetClientOptions, NetProtocol, NetServerOptions, Options, OptionsBuilder,
 };
 pub(crate) use pipeline_graph::{Edge, PipelineGraph};
+pub(crate) use pipeline_version::PipelineVersion;
 
 use std::{collections::HashSet, sync::Arc};
 
@@ -33,9 +34,8 @@ use anyhow::anyhow;
 use crate::{
     api::error::{Result, SpringError},
     pipeline::{
-        pipeline_version::PipelineVersion, pump_model::PumpModel,
-        sink_writer_model::SinkWriterModel, source_reader_model::SourceReaderModel,
-        stream_model::StreamModel,
+        pump_model::PumpModel, sink_writer_model::SinkWriterModel,
+        source_reader_model::SourceReaderModel, stream_model::StreamModel,
     },
 };
 

diff --git a/springql-core/src/sql_processor.rs b/springql-core/src/sql_processor.rs
@@ -132,11 +132,10 @@ mod tests {
     use super::*;
     use crate::{
         pipeline::{
-            pipeline_version::PipelineVersion,
             sink_writer_model::{SinkWriterModel, SinkWriterType},
             source_reader_model::{SourceReaderModel, SourceReaderType},
             stream_model::{StreamModel, StreamShape},
-            OptionsBuilder, SinkWriterName, SourceReaderName, StreamName,
+            OptionsBuilder, PipelineVersion, SinkWriterName, SourceReaderName, StreamName,
         },
         stream_engine::command::alter_pipeline_command::AlterPipelineCommand,
     };

diff --git a/springql-core/src/stream_engine/autonomous_executor/performance_metrics.rs b/springql-core/src/stream_engine/autonomous_executor/performance_metrics.rs
@@ -14,7 +14,7 @@ use std::collections::HashMap;
 use parking_lot::{RwLock, RwLockReadGuard, RwLockWriteGuard};
 
 use crate::{
-    pipeline::pipeline_version::PipelineVersion,
+    pipeline::PipelineVersion,
     stream_engine::autonomous_executor::{
         performance_metrics::{
             metrics_update_command::metrics_update_by_task_execution::MetricsUpdateByTaskExecution,

diff --git a/...utonomous_executor/performance_monitor_worker/web_console_reporter/web_console_request.rs b/...utonomous_executor/performance_monitor_worker/web_console_reporter/web_console_request.rs
@@ -185,7 +185,7 @@ impl QueueInnerRequest {
 
 #[cfg(test)]
 mod tests {
-    use crate::pipeline::pipeline_version::PipelineVersion;
+    use crate::pipeline::PipelineVersion;
 
     use super::*;
     use pretty_assertions::assert_eq;

diff --git a/springql-core/src/stream_engine/autonomous_executor/pipeline_derivatives.rs b/springql-core/src/stream_engine/autonomous_executor/pipeline_derivatives.rs
@@ -6,7 +6,7 @@ use std::sync::Arc;
 
 use crate::{
     api::error::Result,
-    pipeline::{pipeline_version::PipelineVersion, Pipeline},
+    pipeline::{Pipeline, PipelineVersion},
     stream_engine::autonomous_executor::{
         pipeline_derivatives::task_repository::TaskRepository,
         task::Task,

diff --git a/springql-core/src/stream_engine/autonomous_executor/task_graph.rs b/springql-core/src/stream_engine/autonomous_executor/task_graph.rs
@@ -19,7 +19,7 @@ use std::collections::HashMap;
 use petgraph::graph::{DiGraph, NodeIndex};
 
 use crate::{
-    pipeline::{pipeline_version::PipelineVersion, Edge, Pipeline, StreamName},
+    pipeline::{Edge, Pipeline, PipelineVersion, StreamName},
     stream_engine::autonomous_executor::task_graph::{
         edge_ref::MyEdgeRef,
         queue_id::{row_queue_id::RowQueueId, window_queue_id::WindowQueueId, QueueId},

diff --git a/springql-core/src/stream_engine/autonomous_executor/test_support/fixture.rs b/springql-core/src/stream_engine/autonomous_executor/test_support/fixture.rs
@@ -6,9 +6,9 @@ use serde_json::json;
 
 use crate::{
     pipeline::{
-        pipeline_version::PipelineVersion, pump_model::PumpInputType,
-        sink_writer_model::SinkWriterModel, source_reader_model::SourceReaderModel,
-        stream_model::StreamModel, StreamName,
+        pump_model::PumpInputType, sink_writer_model::SinkWriterModel,
+        source_reader_model::SourceReaderModel, stream_model::StreamModel, PipelineVersion,
+        StreamName,
     },
     stream_engine::{
         autonomous_executor::{

diff --git a/springql-core/src/stream_engine/sql_executor.rs b/springql-core/src/stream_engine/sql_executor.rs
@@ -5,9 +5,9 @@ use std::sync::Arc;
 use crate::{
     api::error::Result,
     pipeline::{
-        pipeline_version::PipelineVersion, pump_model::PumpModel,
-        sink_writer_model::SinkWriterModel, source_reader_model::SourceReaderModel,
-        stream_model::StreamModel, Pipeline,
+        pump_model::PumpModel, sink_writer_model::SinkWriterModel,
+        source_reader_model::SourceReaderModel, stream_model::StreamModel, Pipeline,
+        PipelineVersion,
     },
     stream_engine::command::alter_pipeline_command::AlterPipelineCommand,
 };