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