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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

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

mod source_reader_type;
pub use source_reader_type::SourceReaderType;

use crate::pipeline::{
    name::{SourceReaderName, StreamName},
    option::Options,
};

#[derive(Clone, PartialEq, Eq, Debug, new)]
pub struct SourceReaderModel {
    name: SourceReaderName,
    source_reader_type: SourceReaderType,
    dest_source_stream: StreamName,
    options: Options,
}

impl SourceReaderModel {
    pub fn name(&self) -> &SourceReaderName {
        &self.name
    }

    pub fn source_reader_type(&self) -> &SourceReaderType {
        &self.source_reader_type
    }

    pub fn dest_source_stream(&self) -> &StreamName {
        &self.dest_source_stream
    }

    pub fn options(&self) -> &Options {
        &self.options
    }
}