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(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(feature = "sources-mongodb_metrics")]
144pub(crate) use mongodb_metrics::*;
145
146#[cfg(feature = "transforms-aggregate")]
147pub(crate) use self::aggregate::*;
148#[cfg(feature = "sources-amqp")]
149pub(crate) use self::amqp::*;
150#[cfg(feature = "sources-apache_metrics")]
151pub(crate) use self::apache_metrics::*;
152#[cfg(feature = "api")]
153pub(crate) use self::api::*;
154#[cfg(feature = "aws-core")]
155pub(crate) use self::aws::*;
156#[cfg(feature = "sinks-aws_cloudwatch_logs")]
157pub(crate) use self::aws_cloudwatch_logs::*;
158#[cfg(feature = "transforms-aws_ec2_metadata")]
159pub(crate) use self::aws_ec2_metadata::*;
160#[cfg(feature = "sources-aws_ecs_metrics")]
161pub(crate) use self::aws_ecs_metrics::*;
162#[cfg(any(
163    feature = "sinks-aws_kinesis_streams",
164    feature = "sinks-aws_kinesis_firehose"
165))]
166pub(crate) use self::aws_kinesis::*;
167#[cfg(feature = "sources-aws_kinesis_firehose")]
168pub(crate) use self::aws_kinesis_firehose::*;
169#[cfg(any(feature = "sources-aws_s3", feature = "sources-aws_sqs",))]
170pub(crate) use self::aws_sqs::*;
171pub(crate) use self::codecs::*;
172#[cfg(feature = "sources-datadog_agent")]
173pub(crate) use self::datadog_agent::*;
174#[cfg(feature = "sinks-datadog_metrics")]
175pub(crate) use self::datadog_metrics::*;
176#[cfg(feature = "sinks-datadog_traces")]
177pub(crate) use self::datadog_traces::*;
178#[cfg(feature = "transforms-impl-dedupe")]
179pub(crate) use self::dedupe::*;
180#[cfg(feature = "sources-demo_logs")]
181pub(crate) use self::demo_logs::*;
182#[cfg(feature = "sources-dnstap")]
183pub(crate) use self::dnstap::*;
184#[cfg(feature = "sources-docker_logs")]
185pub(crate) use self::docker_logs::*;
186#[cfg(feature = "sources-eventstoredb_metrics")]
187pub(crate) use self::eventstoredb_metrics::*;
188#[cfg(feature = "sources-exec")]
189pub(crate) use self::exec::*;
190#[cfg(any(
191    feature = "sources-file",
192    feature = "sources-kubernetes_logs",
193    feature = "sinks-file",
194))]
195pub(crate) use self::file::*;
196#[cfg(any(feature = "sources-file_descriptor", feature = "sources-stdin"))]
197pub(crate) use self::file_descriptor::*;
198#[cfg(feature = "transforms-filter")]
199pub(crate) use self::filter::*;
200#[cfg(feature = "sources-fluent")]
201pub(crate) use self::fluent::*;
202#[cfg(feature = "sources-gcp_pubsub")]
203pub(crate) use self::gcp_pubsub::*;
204#[cfg(any(feature = "sources-vector", feature = "sources-opentelemetry"))]
205pub(crate) use self::grpc::*;
206#[cfg(feature = "sources-host_metrics")]
207pub(crate) use self::host_metrics::*;
208#[cfg(feature = "sources-utils-http-client")]
209pub(crate) use self::http_client_source::*;
210#[cfg(feature = "sinks-influxdb")]
211pub(crate) use self::influxdb::*;
212#[cfg(feature = "sources-internal_logs")]
213pub(crate) use self::internal_logs::*;
214#[cfg(all(unix, feature = "sources-journald"))]
215pub(crate) use self::journald::*;
216#[cfg(any(feature = "sources-kafka", feature = "sinks-kafka"))]
217pub(crate) use self::kafka::*;
218#[cfg(feature = "sources-kubernetes_logs")]
219pub(crate) use self::kubernetes_logs::*;
220#[cfg(feature = "transforms-log_to_metric")]
221pub(crate) use self::log_to_metric::*;
222#[cfg(feature = "sources-heroku_logs")]
223pub(crate) use self::logplex::*;
224#[cfg(feature = "sinks-loki")]
225pub(crate) use self::loki::*;
226#[cfg(feature = "transforms-lua")]
227pub(crate) use self::lua::*;
228#[cfg(feature = "transforms-metric_to_log")]
229pub(crate) use self::metric_to_log::*;
230#[cfg(feature = "sinks-mqtt")]
231pub(crate) use self::mqtt::*;
232#[cfg(feature = "sources-nginx_metrics")]
233pub(crate) use self::nginx_metrics::*;
234#[allow(unused_imports)]
235pub(crate) use self::parser::*;
236#[cfg(feature = "sources-postgresql_metrics")]
237pub(crate) use self::postgresql_metrics::*;
238#[cfg(any(
239    feature = "sources-prometheus-scrape",
240    feature = "sources-prometheus-remote-write",
241    feature = "sinks-prometheus"
242))]
243pub(crate) use self::prometheus::*;
244#[cfg(any(feature = "sinks-pulsar", feature = "sources-pulsar"))]
245pub(crate) use self::pulsar::*;
246#[cfg(feature = "sources-redis")]
247pub(crate) use self::redis::*;
248#[cfg(feature = "transforms-impl-reduce")]
249pub(crate) use self::reduce::*;
250#[cfg(feature = "transforms-remap")]
251pub(crate) use self::remap::*;
252#[cfg(feature = "transforms-impl-sample")]
253pub(crate) use self::sample::*;
254#[cfg(feature = "sinks-sematext")]
255pub(crate) use self::sematext_metrics::*;
256#[cfg(any(feature = "sources-splunk_hec", feature = "sinks-splunk_hec"))]
257pub(crate) use self::splunk_hec::*;
258#[cfg(feature = "sinks-statsd")]
259pub(crate) use self::statsd_sink::*;
260#[cfg(feature = "transforms-tag_cardinality_limit")]
261pub(crate) use self::tag_cardinality_limit::*;
262#[cfg(feature = "transforms-throttle")]
263pub(crate) use self::throttle::*;
264#[cfg(unix)]
265pub(crate) use self::unix::*;
266#[cfg(feature = "sinks-websocket")]
267pub(crate) use self::websocket::*;
268#[cfg(feature = "sinks-websocket-server")]
269pub(crate) use self::websocket_server::*;
270#[cfg(feature = "transforms-window")]
271pub(crate) use self::window::*;
272#[cfg(windows)]
273pub(crate) use self::windows::*;
274pub use self::{
275    adaptive_concurrency::*, batch::*, common::*, conditions::*, encoding_transcode::*,
276    heartbeat::*, http::*, open::*, process::*, socket::*, tcp::*, template::*, udp::*,
277};
vector/internal_events/mod.rs

vector/internal_events/
mod.rs
