vector/sinks/blackhole/
mod.rs

1mod config;
2mod sink;
3
4pub use config::BlackholeConfig;
5
6#[cfg(test)]
7mod tests {
8
9    use std::time::Duration;
10
11    use crate::{
12        sinks::{
13            VectorSink,
14            blackhole::{config::BlackholeConfig, sink::BlackholeSink},
15        },
16        test_util::{
17            components::{SINK_TAGS, run_and_assert_sink_compliance},
18            random_events_with_stream,
19        },
20    };
21
22    #[tokio::test]
23    async fn blackhole() {
24        let config = BlackholeConfig {
25            print_interval_secs: Duration::from_secs(10),
26            rate: None,
27            acknowledgements: Default::default(),
28        };
29        let sink = BlackholeSink::new(config);
30        let sink = VectorSink::Stream(Box::new(sink));
31
32        let (_input_lines, events) = random_events_with_stream(100, 10, None);
33        run_and_assert_sink_compliance(sink, events, &SINK_TAGS).await;
34    }
35}
vector/sinks/blackhole/mod.rs

vector/sinks/blackhole/
mod.rs
