vector/internal_events/
mod.rs1#![allow(missing_docs)]
2pub mod prelude;
3
4mod adaptive_concurrency;
5#[cfg(feature = "transforms-aggregate")]
6mod aggregate;
7#[cfg(any(feature = "sources-amqp", feature = "sinks-amqp"))]
8mod amqp;
9#[cfg(feature = "sources-apache_metrics")]
10mod apache_metrics;
11#[cfg(feature = "api")]
12mod api;
13#[cfg(feature = "aws-core")]
14mod aws;
15#[cfg(feature = "sinks-aws_cloudwatch_logs")]
16mod aws_cloudwatch_logs;
17#[cfg(feature = "transforms-aws_ec2_metadata")]
18mod aws_ec2_metadata;
19#[cfg(feature = "sources-aws_ecs_metrics")]
20mod aws_ecs_metrics;
21#[cfg(any(
22 feature = "sinks-aws_kinesis_streams",
23 feature = "sinks-aws_kinesis_firehose"
24))]
25mod aws_kinesis;
26#[cfg(feature = "sources-aws_kinesis_firehose")]
27mod aws_kinesis_firehose;
28#[cfg(any(feature = "sources-aws_s3", feature = "sources-aws_sqs",))]
29mod aws_sqs;
30mod batch;
31mod common;
32mod conditions;
33#[cfg(feature = "sources-datadog_agent")]
34mod datadog_agent;
35#[cfg(feature = "sinks-datadog_logs")]
36mod datadog_logs;
37#[cfg(feature = "sinks-datadog_metrics")]
38mod datadog_metrics;
39#[cfg(feature = "sinks-datadog_traces")]
40mod datadog_traces;
41#[cfg(feature = "transforms-impl-dedupe")]
42mod dedupe;
43#[cfg(feature = "sources-demo_logs")]
44mod demo_logs;
45#[cfg(all(unix, feature = "sources-dnstap"))]
46mod dnstap;
47#[cfg(feature = "sources-docker_logs")]
48mod docker_logs;
49#[cfg(feature = "sinks-doris")]
50mod doris;
51mod encoding_transcode;
52#[cfg(feature = "sources-eventstoredb_metrics")]
53mod eventstoredb_metrics;
54#[cfg(feature = "sources-exec")]
55mod exec;
56#[cfg(any(
57 feature = "sources-file",
58 feature = "sources-kubernetes_logs",
59 feature = "sinks-file",
60 feature = "sinks-aws_s3",
61 feature = "sinks-azure_blob",
62 feature = "sinks-gcp",
63 feature = "sinks-webhdfs",
64))]
65mod file;
66#[cfg(any(feature = "sources-file_descriptor", feature = "sources-stdin"))]
67mod file_descriptor;
68#[cfg(feature = "transforms-filter")]
69mod filter;
70#[cfg(feature = "sources-fluent")]
71mod fluent;
72#[cfg(feature = "sources-gcp_pubsub")]
73mod gcp_pubsub;
74#[cfg(any(feature = "sources-vector", feature = "sources-opentelemetry"))]
75mod grpc;
76mod heartbeat;
77#[cfg(feature = "sources-host_metrics")]
78mod host_metrics;
79mod http;
80pub mod http_client;
81#[cfg(feature = "sources-utils-http-client")]
82mod http_client_source;
83#[cfg(feature = "sinks-influxdb")]
84mod influxdb;
85#[cfg(feature = "sources-internal_logs")]
86mod internal_logs;
87#[cfg(all(unix, feature = "sources-journald"))]
88mod journald;
89#[cfg(any(feature = "sources-kafka", feature = "sinks-kafka"))]
90mod kafka;
91#[cfg(feature = "sources-kubernetes_logs")]
92mod kubernetes_logs;
93#[cfg(feature = "transforms-log_to_metric")]
94mod log_to_metric;
95#[cfg(feature = "sources-heroku_logs")]
96mod logplex;
97#[cfg(feature = "sinks-loki")]
98mod loki;
99#[cfg(feature = "transforms-lua")]
100mod lua;
101#[cfg(feature = "transforms-metric_to_log")]
102mod metric_to_log;
103#[cfg(feature = "sources-mongodb_metrics")]
104mod mongodb_metrics;
105#[cfg(feature = "sinks-mqtt")]
106mod mqtt;
107#[cfg(feature = "sources-nginx_metrics")]
108mod nginx_metrics;
109mod open;
110#[cfg(any(
111 feature = "sources-kubernetes_logs",
112 feature = "transforms-log_to_metric",
113 feature = "sinks-datadog_events",
114))]
115mod parser;
116#[cfg(feature = "sources-postgresql_metrics")]
117mod postgresql_metrics;
118mod process;
119#[cfg(any(
120 feature = "sources-prometheus-scrape",
121 feature = "sources-prometheus-remote-write",
122 feature = "sinks-prometheus"
123))]
124mod prometheus;
125#[cfg(any(feature = "sinks-pulsar", feature = "sources-pulsar"))]
126mod pulsar;
127#[cfg(feature = "sources-redis")]
128mod redis;
129#[cfg(feature = "transforms-impl-reduce")]
130mod reduce;
131#[cfg(feature = "transforms-remap")]
132mod remap;
133#[cfg(feature = "transforms-impl-sample")]
134mod sample;
135#[cfg(feature = "sinks-sematext")]
136mod sematext_metrics;
137mod socket;
138#[cfg(any(feature = "sources-splunk_hec", feature = "sinks-splunk_hec"))]
139mod splunk_hec;
140#[cfg(feature = "sinks-statsd")]
141mod statsd_sink;
142#[cfg(feature = "transforms-tag_cardinality_limit")]
143mod tag_cardinality_limit;
144mod tcp;
145mod template;
146#[cfg(feature = "transforms-throttle")]
147mod throttle;
148mod udp;
149#[cfg(unix)]
150mod unix;
151#[cfg(any(feature = "sources-websocket", feature = "sinks-websocket"))]
152mod websocket;
153#[cfg(feature = "sinks-websocket-server")]
154mod websocket_server;
155#[cfg(feature = "transforms-window")]
156mod window;
157#[cfg(all(windows, feature = "sources-windows_event_log"))]
158mod windows_event_log;
159
160#[cfg(windows)]
161mod windows;
162
163#[cfg(any(feature = "transforms-log_to_metric", feature = "sinks-loki"))]
164mod expansion;
165#[cfg(feature = "sources-mongodb_metrics")]
166pub(crate) use mongodb_metrics::*;
167
168#[cfg(feature = "transforms-aggregate")]
169pub(crate) use self::aggregate::*;
170#[cfg(feature = "sources-amqp")]
171pub(crate) use self::amqp::*;
172#[cfg(feature = "sources-apache_metrics")]
173pub(crate) use self::apache_metrics::*;
174#[cfg(feature = "api")]
175pub(crate) use self::api::*;
176#[cfg(feature = "aws-core")]
177pub(crate) use self::aws::*;
178#[cfg(feature = "sinks-aws_cloudwatch_logs")]
179pub(crate) use self::aws_cloudwatch_logs::*;
180#[cfg(feature = "transforms-aws_ec2_metadata")]
181pub(crate) use self::aws_ec2_metadata::*;
182#[cfg(feature = "sources-aws_ecs_metrics")]
183pub(crate) use self::aws_ecs_metrics::*;
184#[cfg(any(
185 feature = "sinks-aws_kinesis_streams",
186 feature = "sinks-aws_kinesis_firehose"
187))]
188pub(crate) use self::aws_kinesis::*;
189#[cfg(feature = "sources-aws_kinesis_firehose")]
190pub(crate) use self::aws_kinesis_firehose::*;
191#[cfg(any(feature = "sources-aws_s3", feature = "sources-aws_sqs",))]
192pub(crate) use self::aws_sqs::*;
193#[cfg(feature = "sources-datadog_agent")]
194pub(crate) use self::datadog_agent::*;
195#[cfg(feature = "sinks-datadog_logs")]
196pub(crate) use self::datadog_logs::*;
197#[cfg(feature = "sinks-datadog_metrics")]
198pub(crate) use self::datadog_metrics::*;
199#[cfg(feature = "sinks-datadog_traces")]
200pub(crate) use self::datadog_traces::*;
201#[cfg(feature = "transforms-impl-dedupe")]
202pub(crate) use self::dedupe::*;
203#[cfg(feature = "sources-demo_logs")]
204pub(crate) use self::demo_logs::*;
205#[cfg(all(unix, feature = "sources-dnstap"))]
206pub(crate) use self::dnstap::*;
207#[cfg(feature = "sources-docker_logs")]
208pub(crate) use self::docker_logs::*;
209#[cfg(feature = "sinks-doris")]
210pub(crate) use self::doris::*;
211#[cfg(feature = "sources-eventstoredb_metrics")]
212pub(crate) use self::eventstoredb_metrics::*;
213#[cfg(feature = "sources-exec")]
214pub(crate) use self::exec::*;
215#[cfg(any(feature = "transforms-log_to_metric", feature = "sinks-loki"))]
216pub use self::expansion::*;
217#[cfg(any(
218 feature = "sources-file",
219 feature = "sources-kubernetes_logs",
220 feature = "sinks-file",
221))]
222pub(crate) use self::file::*;
223#[cfg(any(feature = "sources-file_descriptor", feature = "sources-stdin"))]
224pub(crate) use self::file_descriptor::*;
225#[cfg(feature = "transforms-filter")]
226pub(crate) use self::filter::*;
227#[cfg(feature = "sources-fluent")]
228pub(crate) use self::fluent::*;
229#[cfg(feature = "sources-gcp_pubsub")]
230pub(crate) use self::gcp_pubsub::*;
231#[cfg(any(feature = "sources-vector", feature = "sources-opentelemetry"))]
232pub(crate) use self::grpc::*;
233#[cfg(feature = "sources-host_metrics")]
234pub(crate) use self::host_metrics::*;
235#[cfg(feature = "sources-utils-http-client")]
236pub(crate) use self::http_client_source::*;
237#[cfg(feature = "sinks-influxdb")]
238pub(crate) use self::influxdb::*;
239#[cfg(feature = "sources-internal_logs")]
240pub(crate) use self::internal_logs::*;
241#[cfg(all(unix, feature = "sources-journald"))]
242pub(crate) use self::journald::*;
243#[cfg(any(feature = "sources-kafka", feature = "sinks-kafka"))]
244pub(crate) use self::kafka::*;
245#[cfg(feature = "sources-kubernetes_logs")]
246pub(crate) use self::kubernetes_logs::*;
247#[cfg(feature = "transforms-log_to_metric")]
248pub(crate) use self::log_to_metric::*;
249#[cfg(feature = "sources-heroku_logs")]
250pub(crate) use self::logplex::*;
251#[cfg(feature = "sinks-loki")]
252pub(crate) use self::loki::*;
253#[cfg(feature = "transforms-lua")]
254pub(crate) use self::lua::*;
255#[cfg(feature = "transforms-metric_to_log")]
256pub(crate) use self::metric_to_log::*;
257#[cfg(feature = "sinks-mqtt")]
258pub(crate) use self::mqtt::*;
259#[cfg(feature = "sources-nginx_metrics")]
260pub(crate) use self::nginx_metrics::*;
261#[cfg(any(
262 feature = "sources-kubernetes_logs",
263 feature = "transforms-log_to_metric",
264 feature = "sinks-datadog_events",
265))]
266pub(crate) use self::parser::*;
267#[cfg(feature = "sources-postgresql_metrics")]
268pub(crate) use self::postgresql_metrics::*;
269#[cfg(any(
270 feature = "sources-prometheus-scrape",
271 feature = "sources-prometheus-remote-write",
272 feature = "sinks-prometheus"
273))]
274pub(crate) use self::prometheus::*;
275#[cfg(any(feature = "sinks-pulsar", feature = "sources-pulsar"))]
276pub(crate) use self::pulsar::*;
277#[cfg(feature = "sources-redis")]
278pub(crate) use self::redis::*;
279#[cfg(feature = "transforms-impl-reduce")]
280pub(crate) use self::reduce::*;
281#[cfg(feature = "transforms-remap")]
282pub(crate) use self::remap::*;
283#[cfg(feature = "transforms-impl-sample")]
284pub(crate) use self::sample::*;
285#[cfg(feature = "sinks-sematext")]
286pub(crate) use self::sematext_metrics::*;
287#[cfg(any(feature = "sources-splunk_hec", feature = "sinks-splunk_hec"))]
288pub(crate) use self::splunk_hec::*;
289#[cfg(feature = "sinks-statsd")]
290pub(crate) use self::statsd_sink::*;
291#[cfg(feature = "transforms-tag_cardinality_limit")]
292pub(crate) use self::tag_cardinality_limit::*;
293#[cfg(feature = "transforms-throttle")]
294pub(crate) use self::throttle::*;
295#[cfg(unix)]
296pub(crate) use self::unix::*;
297#[cfg(any(feature = "sources-websocket", feature = "sinks-websocket"))]
298pub(crate) use self::websocket::*;
299#[cfg(feature = "sinks-websocket-server")]
300pub(crate) use self::websocket_server::*;
301#[cfg(feature = "transforms-window")]
302pub(crate) use self::window::*;
303#[cfg(windows)]
304pub(crate) use self::windows::*;
305#[cfg(all(windows, feature = "sources-windows_event_log"))]
306pub(crate) use self::windows_event_log::*;
307pub use self::{
308 adaptive_concurrency::*, batch::*, common::*, conditions::*, encoding_transcode::*,
309 heartbeat::*, http::*, open::*, process::*, socket::*, tcp::*, template::*, udp::*,
310};