ref(types): Rework how types are structured and exported (supabase#290)

Author: iambriccardo

etl-api/src/routes/pipelines.rs

@@ -7,7 +7,7 @@ use actix_web::{
 use chrono::Utc;
 use etl_config::shared::{ReplicatorConfig, SupabaseConfig, TlsConfig};
 use etl_postgres::replication::{TableLookupError, get_table_name_from_oid, health, state};
-use etl_postgres::schema::TableId;
+use etl_postgres::types::TableId;
 use secrecy::ExposeSecret;
 use serde::{Deserialize, Serialize};
 use sqlx::{PgPool, PgTransaction};

etl-benchmarks/benches/table_copies.rs

@@ -8,7 +8,7 @@ use etl::types::{Event, TableRow};
 use etl_config::Environment;
 use etl_config::shared::{BatchConfig, PgConnectionConfig, PipelineConfig, TlsConfig};
 use etl_destinations::bigquery::{BigQueryDestination, install_crypto_provider_for_bigquery};
-use etl_postgres::schema::TableId;
+use etl_postgres::types::TableId;
 use etl_telemetry::tracing::init_tracing;
 use sqlx::postgres::PgPool;
 use std::error::Error;

etl-destinations/Cargo.toml

@@ -16,7 +16,6 @@ iceberg = ["dep:iceberg", "dep:iceberg-catalog-rest"]
 
 [dependencies]
 etl = { workspace = true }
-etl-postgres = { workspace = true }
 chrono = { workspace = true }
 
 futures = { workspace = true, optional = true }

etl-destinations/src/bigquery/client.rs

@@ -1,7 +1,6 @@
 use etl::error::{ErrorKind, EtlError, EtlResult};
 use etl::etl_error;
-use etl::types::{Cell, ColumnSchema, TableRow, Type};
-use etl_postgres::types::is_array_type;
+use etl::types::{Cell, ColumnSchema, TableRow, Type, is_array_type};
 use gcp_bigquery_client::google::cloud::bigquery::storage::v1::RowError;
 use gcp_bigquery_client::storage::ColumnMode;
 use gcp_bigquery_client::yup_oauth2::parse_service_account_key;

etl-destinations/src/bigquery/encoding.rs

@@ -1,8 +1,10 @@
 use crate::bigquery::validation::validate_cell_for_bigquery;
 use etl::error::EtlError;
 use etl::etl_error;
-use etl::types::{ArrayCellNonOptional, CellNonOptional, TableRow};
-use etl_postgres::time::{DATE_FORMAT, TIME_FORMAT, TIMESTAMP_FORMAT, TIMESTAMPTZ_FORMAT_HH_MM};
+use etl::types::{
+    ArrayCellNonOptional, CellNonOptional, DATE_FORMAT, TIME_FORMAT, TIMESTAMP_FORMAT,
+    TIMESTAMPTZ_FORMAT_HH_MM, TableRow,
+};
 use prost::bytes;
 
 /// Protocol buffer wrapper for a BigQuery table row containing non-optional cells.

etl-destinations/src/iceberg/schema.rs

@@ -1,7 +1,6 @@
 use std::sync::Arc;
 
-use etl::types::{TableSchema, Type};
-use etl_postgres::types::is_array_type;
+use etl::types::{TableSchema, Type, is_array_type};
 use iceberg::spec::{
     ListType, NestedField, PrimitiveType, Schema as IcebergSchema, Type as IcebergType,
 };

etl-postgres/.sqlx/query-bc8119f0a137815cb238b9b2bdec2160ff9d6eb23e2e0bd92f3d1581bc4a30e0.json

@@ -5,10 +5,8 @@
 
 #[cfg(feature = "replication")]
 pub mod replication;
-pub mod schema;
 #[cfg(feature = "sqlx")]
 pub mod sqlx;
-pub mod time;
 #[cfg(feature = "tokio")]
 pub mod tokio;
 pub mod types;

etl-postgres/src/lib.rs

@@ -2,7 +2,7 @@ use etl_config::shared::{IntoConnectOptions, PgConnectionConfig};
 use sqlx::{PgPool, Row, postgres::PgPoolOptions};
 use thiserror::Error;
 
-use crate::schema::{TableId, TableName};
+use crate::types::{TableId, TableName};
 
 /// Errors that can occur during table lookups.
 #[derive(Debug, Error)]

etl-postgres/src/replication/db.rs

@@ -4,7 +4,7 @@ use sqlx::{PgExecutor, PgPool, Row};
 use std::collections::HashMap;
 use tokio_postgres::types::Type as PgType;
 
-use crate::schema::{ColumnSchema, TableId, TableName, TableSchema};
+use crate::types::{ColumnSchema, TableId, TableName, TableSchema};
 
 macro_rules! define_type_mappings {
     (