arkflow-plugin 0.1.0

High-performance Rust flow processing engine
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

//! Input component module
//!
//! The input component is responsible for receiving data from various sources such as message queues, file systems, HTTP endpoints, and so on.

use std::sync::OnceLock;

pub mod file;
pub mod generate;
pub mod http;
pub mod kafka;
pub mod memory;
pub mod mqtt;
pub mod sql;

lazy_static::lazy_static! {
    static ref INITIALIZED: OnceLock<()> = OnceLock::new();
}

pub fn init() {
    INITIALIZED.get_or_init(|| {
        file::init();
        generate::init();
        http::init();
        kafka::init();
        memory::init();
        mqtt::init();
        sql::init();
    });
}