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", feature = "dst_arrow"))]
18mod mssql_arrow;
19#[cfg(all(feature = "src_mssql", 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_mssql", feature = "dst_arrow"))]
60pub use mssql_arrow::{MsSQLArrowTransport, MsSQLArrowTransportError};
61#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
62pub use mssql_arrowstream::{
63    MsSQLArrowTransport as MsSQLArrowStreamTransport,
64    MsSQLArrowTransportError as MsSQLArrowStreamTransportError,
65};
66#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
67pub use mysql_arrow::{MySQLArrowTransport, MySQLArrowTransportError};
68#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
69pub use mysql_arrowstream::{
70    MySQLArrowTransport as MySQLArrowStreamTransport,
71    MySQLArrowTransportError as MySQLArrowStreamTransportError,
72};
73#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
74pub use oracle_arrow::{OracleArrowTransport, OracleArrowTransportError};
75#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
76pub use oracle_arrowstream::{
77    OracleArrowTransport as OracleArrowStreamTransport,
78    OracleArrowTransportError as OracleArrowStreamTransportError,
79};
80#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
81pub use postgres_arrow::{PostgresArrowTransport, PostgresArrowTransportError};
82#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
83pub use postgres_arrowstream::{
84    PostgresArrowTransport as PostgresArrowStreamTransport,
85    PostgresArrowTransportError as PostgresArrowStreamTransportError,
86};
87#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
88pub use sqlite_arrow::{SQLiteArrowTransport, SQLiteArrowTransportError};
89#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
90pub use sqlite_arrowstream::{
91    SQLiteArrowTransport as SQLiteArrowStreamTransport,
92    SQLiteArrowTransportError as SQLiteArrowStreamTransportError,
93};
94#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
95pub use trino_arrow::{TrinoArrowTransport, TrinoArrowTransportError};
96#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
97pub use trino_arrowstream::{
98    TrinoArrowTransport as TrinoArrowStreamTransport,
99    TrinoArrowTransportError as TrinoArrowStreamTransportError,
100};
connectorx/transports/mod.rs

connectorx/transports/
mod.rs
