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

vector/internal_events/
mod.rs
