arkflow_plugin/input/
mod.rs

1//! Input component module
2//!
3//! The input component is responsible for receiving data from various sources such as message queues, file systems, HTTP endpoints, and so on.
4
5use std::sync::OnceLock;
6
7pub mod file;
8pub mod generate;
9pub mod http;
10pub mod kafka;
11pub mod memory;
12pub mod mqtt;
13pub mod sql;
14
15lazy_static::lazy_static! {
16    static ref INITIALIZED: OnceLock<()> = OnceLock::new();
17}
18
19pub fn init() {
20    INITIALIZED.get_or_init(|| {
21        file::init();
22        generate::init();
23        http::init();
24        kafka::init();
25        memory::init();
26        mqtt::init();
27        sql::init();
28    });
29}