laminar_connectors/lookup/mod.rs
1//! Lookup tables for enrichment joins.
2//!
3//! Production code uses `laminar_core::lookup::LookupSource` for the
4//! actual on-demand lookups; this module hosts the reference-table
5//! adapters (CDC, Delta Lake, Postgres) that hydrate those caches.
6
7/// CDC-to-reference-table adapter for using CDC sources as lookup tables.
8pub mod cdc_adapter;
9
10/// Delta Lake reference table source for lookup/enrichment joins.
11pub mod delta_reference;
12
13/// Delta Lake on-demand lookup source for cache-miss fallback.
14#[cfg(feature = "delta-lake")]
15pub mod delta_lookup;
16
17/// Iceberg on-demand lookup source for cache-miss fallback.
18#[cfg(feature = "iceberg")]
19pub mod iceberg_lookup;
20
21/// PostgreSQL poll-based reference table source (no CDC required).
22#[cfg(feature = "postgres-cdc")]
23pub mod postgres_reference;
24
25/// PostgreSQL on-demand lookup source (pooled, `WHERE pk = ANY($1)`).
26#[cfg(feature = "postgres-cdc")]
27pub mod postgres_lookup;
28
29// Re-export the canonical lookup types from laminar-core.
30pub use laminar_core::lookup::{LookupError, LookupResult};