vector/internal_events/
mod.rs

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

vector/internal_events/
mod.rs
