arkflow_plugin/output/
mod.rs

1//! Output component module
2//!
3//! The output component is responsible for sending the processed data to the target system.
4
5use std::sync::OnceLock;
6
7pub mod drop;
8pub mod file;
9pub mod http;
10pub mod kafka;
11pub mod mqtt;
12pub mod stdout;
13
14lazy_static::lazy_static! {
15    static ref INITIALIZED: OnceLock<()> = OnceLock::new();
16}
17
18pub fn init() {
19    INITIALIZED.get_or_init(|| {
20        drop::init();
21        file::init();
22        http::init();
23        kafka::init();
24        mqtt::init();
25        stdout::init();
26    });
27}