Keryxlib is a system for parsing postgres WAL logs and turning them into json events.
The basic algorithm for this is:
Parse the WAL log and create a wal.Entry record. This is a basic record that contains basic WAL data.
Entry records are buffered until either a commit or a rollback is detected. Entries that are rolled back are discarded.
On commit each entry is turned into a message.Message record.
Each message is populated by querying the postgres RDBMS.
Messages are added to a message.Transaction record for delivery.