springql-core 0.18.1

SpringQL: Open-source stream processor for IoT devices and in-vehicle computers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// 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.

use std::sync::Arc;

use crate::pipeline::{
    name::StreamName, pump_model::PumpModel, sink_writer_model::SinkWriterModel,
    source_reader_model::SourceReaderModel,
};

#[derive(Clone, Debug)]
pub enum Edge {
    Pump {
        /// A pump can have 2 or more upstreams (on JOIN, for example). Then, graph edges share the same PumpModel.
        pump_model: Arc<PumpModel>,
        upstream: StreamName,
    },
    Source(SourceReaderModel),
    Sink(SinkWriterModel),
}