Skip to main content

Module changelog

laminar_connectors::cdc::postgres

Module changelog 

Source
Expand description

Z-set changelog integration for PostgreSQL CDC events.

Converts decoded pgoutput DML messages into change events compatible with LaminarDB’s changelog/retraction model (Z-sets).

§Z-Set Semantics

  • INSERT → weight +1 (new row)
  • DELETE → weight -1 (retracted row)
  • UPDATE → weight -1 (old row) + weight +1 (new row)

Structs§

ChangeEvent
A single change event from CDC.

Enums§

CdcOperation
A CDC operation type.

Functions§

events_to_record_batch
Converts a batch of ChangeEvents into an Arrow [RecordBatch] using the CDC envelope schema.
tuple_to_json
Converts tuple data to a JSON string using column names from the relation.