connectorx/transports/
mod.rs

1//! This module contains transport definitions for the sources and destinations implemented in ConnectorX.
2
3#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
4mod bigquery_arrow;
5#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
6mod bigquery_arrowstream;
7#[cfg(all(feature = "src_clickhouse", feature = "dst_arrow"))]
8mod clickhouse_arrow;
9#[cfg(all(feature = "src_clickhouse", feature = "dst_arrow"))]
10mod clickhouse_arrowstream;
11#[cfg(all(feature = "src_csv", feature = "dst_arrow"))]
12mod csv_arrow;
13#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
14mod dummy_arrow;
15#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
16mod dummy_arrowstream;
17#[cfg(all(feature = "src_mssql_common", feature = "dst_arrow"))]
18mod mssql_arrow;
19#[cfg(all(feature = "src_mssql_common", feature = "dst_arrow"))]
20mod mssql_arrowstream;
21#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
22mod mysql_arrow;
23#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
24mod mysql_arrowstream;
25#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
26mod oracle_arrow;
27#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
28mod oracle_arrowstream;
29#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
30mod postgres_arrow;
31#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
32mod postgres_arrowstream;
33#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
34mod sqlite_arrow;
35#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
36mod sqlite_arrowstream;
37#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
38mod trino_arrow;
39#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
40mod trino_arrowstream;
41#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
42pub use bigquery_arrow::{BigQueryArrowTransport, BigQueryArrowTransportError};
43#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
44pub use bigquery_arrowstream::{
45    BigQueryArrowTransport as BigQueryArrowStreamTransport,
46    BigQueryArrowTransportError as BigQueryArrowStreamTransportError,
47};
48#[cfg(all(feature = "src_clickhouse", feature = "dst_arrow"))]
49pub use clickhouse_arrow::{ClickHouseArrowTransport, ClickHouseArrowTransportError};
50#[cfg(all(feature = "src_clickhouse", feature = "dst_arrow"))]
51pub use clickhouse_arrowstream::{
52    ClickHouseArrowStreamTransport,
53    ClickHouseArrowTransportError as ClickHouseArrowStreamTransportError,
54};
55#[cfg(all(feature = "src_csv", feature = "dst_arrow"))]
56pub use csv_arrow::CSVArrowTransport;
57#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
58pub use dummy_arrow::DummyArrowTransport;
59#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
60pub use dummy_arrowstream::{
61    DummyArrowTransport as DummyArrowStreamTransport,
62    DummyArrowTransportError as DummyArrowStreamTransportError,
63};
64#[cfg(all(feature = "src_mssql_common", feature = "dst_arrow"))]
65pub use mssql_arrow::{MsSQLArrowTransport, MsSQLArrowTransportError};
66#[cfg(all(feature = "src_mssql_common", feature = "dst_arrow"))]
67pub use mssql_arrowstream::{
68    MsSQLArrowTransport as MsSQLArrowStreamTransport,
69    MsSQLArrowTransportError as MsSQLArrowStreamTransportError,
70};
71#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
72pub use mysql_arrow::{MySQLArrowTransport, MySQLArrowTransportError};
73#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
74pub use mysql_arrowstream::{
75    MySQLArrowTransport as MySQLArrowStreamTransport,
76    MySQLArrowTransportError as MySQLArrowStreamTransportError,
77};
78#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
79pub use oracle_arrow::{OracleArrowTransport, OracleArrowTransportError};
80#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
81pub use oracle_arrowstream::{
82    OracleArrowTransport as OracleArrowStreamTransport,
83    OracleArrowTransportError as OracleArrowStreamTransportError,
84};
85#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
86pub use postgres_arrow::{PostgresArrowTransport, PostgresArrowTransportError};
87#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
88pub use postgres_arrowstream::{
89    PostgresArrowTransport as PostgresArrowStreamTransport,
90    PostgresArrowTransportError as PostgresArrowStreamTransportError,
91};
92#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
93pub use sqlite_arrow::{SQLiteArrowTransport, SQLiteArrowTransportError};
94#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
95pub use sqlite_arrowstream::{
96    SQLiteArrowTransport as SQLiteArrowStreamTransport,
97    SQLiteArrowTransportError as SQLiteArrowStreamTransportError,
98};
99#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
100pub use trino_arrow::{TrinoArrowTransport, TrinoArrowTransportError};
101#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
102pub use trino_arrowstream::{
103    TrinoArrowTransport as TrinoArrowStreamTransport,
104    TrinoArrowTransportError as TrinoArrowStreamTransportError,
105};
connectorx/transports/mod.rs

connectorx/transports/
mod.rs
