springql_core/sql_processor/sql_parser/
parse_success.rs

1// This file is part of https://github.com/SpringQL/SpringQL which is licensed under MIT OR Apache-2.0. See file LICENSE-MIT or LICENSE-APACHE for full license details.
2
3use crate::{
4    pipeline::{PumpName, SinkWriterModel, SourceReaderModel, StreamModel},
5    sql_processor::sql_parser::syntax::SelectStreamSyntax,
6    stream_engine::command::InsertPlan,
7};
8
9#[allow(clippy::enum_variant_names)]
10#[derive(Clone, PartialEq, Debug)]
11pub enum ParseSuccess {
12    CreateSourceStream(StreamModel),
13    CreateSourceReader(SourceReaderModel),
14    CreateStream(StreamModel),
15    CreateSinkStream(StreamModel),
16    CreateSinkWriter(SinkWriterModel),
17    CreatePump(Box<CreatePump>),
18}
19
20#[derive(Clone, PartialEq, Debug)]
21pub struct CreatePump {
22    pub pump_name: PumpName,
23    pub select_stream_syntax: SelectStreamSyntax,
24    pub insert_plan: InsertPlan,
25}