Module: Pcrd::Replication::Pgoutput::Messages

Defined in:

lib/pcrd/replication/pgoutput/messages.rb

Overview

Immutable structs for each pgoutput message type. Produced by Parser#parse; consumed by the WAL consumer (Phase 9).

Tuple data (new_tuple / old_tuple) is a Hash<column_name, value> where:

value = String  — column value in text format
value = nil     — SQL NULL
value = :toast  — unchanged TOASTed value (not re-sent by server)

Defined Under Namespace

Classes: Begin, Commit, Delete, Insert, LogicalMessage, Origin, Relation, RelationColumn, Truncate, Type, Update