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            blackhole::{config::BlackholeConfig, sink::BlackholeSink},
14            VectorSink,
15        },
16        test_util::{
17            components::run_and_assert_nonsending_sink_compliance, random_events_with_stream,
18        },
19    };
20
21    #[tokio::test]
22    async fn blackhole() {
23        let config = BlackholeConfig {
24            print_interval_secs: Duration::from_secs(10),
25            rate: None,
26            acknowledgements: Default::default(),
27        };
28        let sink = BlackholeSink::new(config);
29        let sink = VectorSink::Stream(Box::new(sink));
30
31        let (_input_lines, events) = random_events_with_stream(100, 10, None);
32        run_and_assert_nonsending_sink_compliance(sink, events, &[]).await;
33    }
34}
vector/sinks/blackhole/mod.rs

vector/sinks/blackhole/
mod.rs
