Skip to main content

Module source

Module source 

Source
Expand description

PostgreSQL CDC source connector implementation.

Implements SourceConnector for streaming logical replication changes from PostgreSQL into LaminarDB as Arrow RecordBatches.

§Architecture

  • Ring 0: No CDC code — just SPSC channel pop (~5ns)
  • Ring 1: WAL consumption, pgoutput parsing, Arrow conversion
  • Ring 2: Slot management, schema discovery, health checks

Structs§

PostgresCdcSource
PostgreSQL CDC source connector.