Parses logical replication messages from Postgres pgoutput plugin
Limited documentation can be found here
The package can be installed by adding pgoutput_decoder to your list of dependencies in mix.exs:
def deps do
[
{:pgoutput_decoder, "~> 0.1.0"}
]
endTo decode messages from Postgres, simply pass them to PgoutputDecoder.decode_message like so:
iex(1)> PgoutputDecoder.decode_message(
<<82, 0, 0, 96, 0, 112, 117, 98, 108, 105, 99, 0, 102, 111, 111, 0, 100, 0, 2, 0, 98,
97, 114, 0, 0, 0, 0, 25, 255, 255, 255, 255, 1, 105, 100, 0, 0, 0, 0, 23, 255, 255,
255, 255>>
)
%PgoutputDecoder.Messages.Relation{
columns: [
%PgoutputDecoder.Messages.Relation.Column{
flags: [],
name: "bar",
type: :text,
type_modifier: 4294967295
},
%PgoutputDecoder.Messages.Relation.Column{
flags: [:key],
name: "id",
type: :int4,
type_modifier: 4294967295
}
],
id: 24576,
name: "foo",
namespace: "public",
replica_identity: :default
}