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_csv", feature = "dst_arrow"))]
8mod csv_arrow;
9#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
10mod dummy_arrow;
11#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
12mod dummy_arrowstream;
13#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
14mod mssql_arrow;
15#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
16mod mssql_arrowstream;
17#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
18mod mysql_arrow;
19#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
20mod mysql_arrowstream;
21#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
22mod oracle_arrow;
23#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
24mod oracle_arrowstream;
25#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
26mod postgres_arrow;
27#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
28mod postgres_arrowstream;
29#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
30mod sqlite_arrow;
31#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
32mod sqlite_arrowstream;
33#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
34mod trino_arrow;
35#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
36mod trino_arrowstream;
37#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
38pub use bigquery_arrow::{BigQueryArrowTransport, BigQueryArrowTransportError};
39#[cfg(all(feature = "src_bigquery", feature = "dst_arrow"))]
40pub use bigquery_arrowstream::{
41    BigQueryArrowTransport as BigQueryArrowStreamTransport,
42    BigQueryArrowTransportError as BigQueryArrowStreamTransportError,
43};
44#[cfg(all(feature = "src_csv", feature = "dst_arrow"))]
45pub use csv_arrow::CSVArrowTransport;
46#[cfg(all(feature = "src_dummy", feature = "dst_arrow"))]
47pub use dummy_arrow::DummyArrowTransport;
48#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
49pub use mssql_arrow::{MsSQLArrowTransport, MsSQLArrowTransportError};
50#[cfg(all(feature = "src_mssql", feature = "dst_arrow"))]
51pub use mssql_arrowstream::{
52    MsSQLArrowTransport as MsSQLArrowStreamTransport,
53    MsSQLArrowTransportError as MsSQLArrowStreamTransportError,
54};
55#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
56pub use mysql_arrow::{MySQLArrowTransport, MySQLArrowTransportError};
57#[cfg(all(feature = "src_mysql", feature = "dst_arrow"))]
58pub use mysql_arrowstream::{
59    MySQLArrowTransport as MySQLArrowStreamTransport,
60    MySQLArrowTransportError as MySQLArrowStreamTransportError,
61};
62#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
63pub use oracle_arrow::{OracleArrowTransport, OracleArrowTransportError};
64#[cfg(all(feature = "src_oracle", feature = "dst_arrow"))]
65pub use oracle_arrowstream::{
66    OracleArrowTransport as OracleArrowStreamTransport,
67    OracleArrowTransportError as OracleArrowStreamTransportError,
68};
69#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
70pub use postgres_arrow::{PostgresArrowTransport, PostgresArrowTransportError};
71#[cfg(all(feature = "src_postgres", feature = "dst_arrow"))]
72pub use postgres_arrowstream::{
73    PostgresArrowTransport as PostgresArrowStreamTransport,
74    PostgresArrowTransportError as PostgresArrowStreamTransportError,
75};
76#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
77pub use sqlite_arrow::{SQLiteArrowTransport, SQLiteArrowTransportError};
78#[cfg(all(feature = "src_sqlite", feature = "dst_arrow"))]
79pub use sqlite_arrowstream::{
80    SQLiteArrowTransport as SQLiteArrowStreamTransport,
81    SQLiteArrowTransportError as SQLiteArrowStreamTransportError,
82};
83#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
84pub use trino_arrow::{TrinoArrowTransport, TrinoArrowTransportError};
85#[cfg(all(feature = "src_trino", feature = "dst_arrow"))]
86pub use trino_arrowstream::{
87    TrinoArrowTransport as TrinoArrowStreamTransport,
88    TrinoArrowTransportError as TrinoArrowStreamTransportError,
89};
connectorx/transports/mod.rs

connectorx/transports/
mod.rs
