vector/internal_events/
mod.rs

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

vector/internal_events/
mod.rs
