vector/sources/
mod.rs

1#![allow(missing_docs)]
2use snafu::Snafu;
3
4#[cfg(feature = "sources-amqp")]
5pub mod amqp;
6#[cfg(feature = "sources-apache_metrics")]
7pub mod apache_metrics;
8#[cfg(feature = "sources-aws_ecs_metrics")]
9pub mod aws_ecs_metrics;
10#[cfg(feature = "sources-aws_kinesis_firehose")]
11pub mod aws_kinesis_firehose;
12#[cfg(feature = "sources-aws_s3")]
13pub mod aws_s3;
14#[cfg(feature = "sources-aws_sqs")]
15pub mod aws_sqs;
16#[cfg(feature = "sources-datadog_agent")]
17pub mod datadog_agent;
18#[cfg(feature = "sources-demo_logs")]
19pub mod demo_logs;
20#[cfg(feature = "sources-dnstap")]
21pub mod dnstap;
22#[cfg(feature = "sources-docker_logs")]
23pub mod docker_logs;
24#[cfg(feature = "sources-eventstoredb_metrics")]
25pub mod eventstoredb_metrics;
26#[cfg(feature = "sources-exec")]
27pub mod exec;
28#[cfg(feature = "sources-file")]
29pub mod file;
30#[cfg(any(
31    feature = "sources-stdin",
32    all(unix, feature = "sources-file_descriptor")
33))]
34pub mod file_descriptors;
35#[cfg(feature = "sources-fluent")]
36pub mod fluent;
37#[cfg(feature = "sources-gcp_pubsub")]
38pub mod gcp_pubsub;
39#[cfg(feature = "sources-heroku_logs")]
40pub mod heroku_logs;
41#[cfg(feature = "sources-host_metrics")]
42pub mod host_metrics;
43#[cfg(feature = "sources-http_client")]
44pub mod http_client;
45#[cfg(feature = "sources-http_server")]
46pub mod http_server;
47#[cfg(feature = "sources-internal_logs")]
48pub mod internal_logs;
49#[cfg(feature = "sources-internal_metrics")]
50pub mod internal_metrics;
51#[cfg(all(unix, feature = "sources-journald"))]
52pub mod journald;
53#[cfg(feature = "sources-kafka")]
54pub mod kafka;
55#[cfg(feature = "sources-kubernetes_logs")]
56pub mod kubernetes_logs;
57#[cfg(feature = "sources-logstash")]
58pub mod logstash;
59#[cfg(feature = "sources-mongodb_metrics")]
60pub mod mongodb_metrics;
61#[cfg(feature = "sources-mqtt")]
62pub mod mqtt;
63#[cfg(feature = "sources-nats")]
64pub mod nats;
65#[cfg(feature = "sources-nginx_metrics")]
66pub mod nginx_metrics;
67#[cfg(feature = "sources-okta")]
68pub mod okta;
69#[cfg(feature = "sources-opentelemetry")]
70pub mod opentelemetry;
71#[cfg(feature = "sources-postgresql_metrics")]
72pub mod postgresql_metrics;
73#[cfg(any(
74    feature = "sources-prometheus-scrape",
75    feature = "sources-prometheus-remote-write",
76    feature = "sources-prometheus-pushgateway"
77))]
78pub mod prometheus;
79#[cfg(feature = "sources-pulsar")]
80pub mod pulsar;
81#[cfg(feature = "sources-redis")]
82pub mod redis;
83#[cfg(feature = "sources-socket")]
84pub mod socket;
85#[cfg(feature = "sources-splunk_hec")]
86pub mod splunk_hec;
87#[cfg(feature = "sources-static_metrics")]
88pub mod static_metrics;
89#[cfg(feature = "sources-statsd")]
90pub mod statsd;
91#[cfg(feature = "sources-syslog")]
92pub mod syslog;
93#[cfg(feature = "sources-vector")]
94pub mod vector;
95#[cfg(feature = "sources-websocket")]
96pub mod websocket;
97
98pub mod util;
99
100pub use vector_lib::source::Source;
101
102#[allow(dead_code)] // Easier than listing out all the features that use this
103/// Common build errors
104#[derive(Debug, Snafu)]
105enum BuildError {
106    #[snafu(display("URI parse error: {}", source))]
107    UriParseError { source: ::http::uri::InvalidUri },
108}
vector/sources/mod.rs

vector/sources/
mod.rs
