1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
#[cfg(feature = "amqp")]
pub mod amqp;
#[cfg(feature = "aws")]
pub mod aws;
#[cfg(feature = "clickhouse")]
pub mod clickhouse;
#[cfg(feature = "grpc")]
pub mod grpc;
#[cfg(feature = "http")]
pub mod http;
#[cfg(feature = "http")]
pub mod http_tls;
#[cfg(any(feature = "ibm-mq-static", feature = "ibm-mq"))]
pub mod ibm_mq;
#[cfg(any(feature = "ibm-mq-static", feature = "ibm-mq"))]
pub mod ibm_mq_tls;
#[cfg(feature = "kafka")]
pub mod kafka;
#[cfg(feature = "sqlx")]
pub mod mariadb;
#[cfg(feature = "mongodb")]
pub mod mongodb;
#[cfg(feature = "mongodb")]
pub mod mongodb_raw;
#[cfg(feature = "mqtt")]
pub mod mqtt;
#[cfg(feature = "sqlx")]
pub mod mysql;
#[cfg(feature = "nats")]
pub mod nats;
#[cfg(feature = "object-store")]
pub mod object_store;
#[cfg(feature = "sqlx")]
pub mod postgres;
#[cfg(all(feature = "postgres-cdc", feature = "test-utils"))]
pub mod postgres_cdc;
#[cfg(feature = "redis-streams")]
pub mod redis_streams;
#[cfg(feature = "sqlx")]
pub mod sqlite;
pub mod tls_helpers;
#[cfg(feature = "websocket")]
pub mod websocket;
#[cfg(feature = "zeromq")]
pub mod zeromq;
pub mod file;
pub mod ipc;
pub mod logic_test;
pub mod memory;
// performance_static was just for internal optimiztion - not a real test
#[cfg(feature = "grpc")]
pub mod grpc_tls;
pub mod route;