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

//! Output component module
//!
//! The output component is responsible for sending the processed data to the target system.

use std::sync::OnceLock;

pub mod drop;
pub mod file;
pub mod http;
pub mod kafka;
pub mod mqtt;
pub mod stdout;

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

pub fn init() {
    INITIALIZED.get_or_init(|| {
        drop::init();
        file::init();
        http::init();
        kafka::init();
        mqtt::init();
        stdout::init();
    });
}