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