diff options
| author | Amit Kapila <akapila@postgresql.org> | 2021-04-06 08:40:47 +0530 |
|---|---|---|
| committer | Amit Kapila <akapila@postgresql.org> | 2021-04-06 08:40:47 +0530 |
| commit | ac4645c0157fc5fcef0af8ff571512aa284a2cec (patch) | |
| tree | a414a4b21e4a79ac04cd67b8ed4ac907d9856f76 /doc/src | |
| parent | 531737ddad214cb8a675953208e2f3a6b1be122b (diff) | |
| download | postgresql-ac4645c0157fc5fcef0af8ff571512aa284a2cec.tar.gz postgresql-ac4645c0157fc5fcef0af8ff571512aa284a2cec.zip | |
Allow pgoutput to send logical decoding messages.
The output plugin accepts a new parameter (messages) that controls if
logical decoding messages are written into the replication stream. It is
useful for those clients that use pgoutput as an output plugin and needs
to process messages that were written by pg_logical_emit_message().
Although logical streaming replication protocol supports logical
decoding messages now, logical replication does not use this feature yet.
Author: David Pirotte, Euler Taveira
Reviewed-by: Euler Taveira, Andres Freund, Ashutosh Bapat, Amit Kapila
Discussion: https://postgr.es/m/CADK3HHJ-+9SO7KuRLH=9Wa1rAo60Yreq1GFNkH_kd0=CdaWM+A@mail.gmail.com
Diffstat (limited to 'doc/src')
| -rw-r--r-- | doc/src/sgml/protocol.sgml | 76 |
1 files changed, 76 insertions, 0 deletions
diff --git a/doc/src/sgml/protocol.sgml b/doc/src/sgml/protocol.sgml index 43092fe62a6..380be5fb17c 100644 --- a/doc/src/sgml/protocol.sgml +++ b/doc/src/sgml/protocol.sgml @@ -6435,6 +6435,82 @@ Begin <varlistentry> <term> +Message +</term> +<listitem> +<para> + +<variablelist> +<varlistentry> +<term> + Byte1('M') +</term> +<listitem> +<para> + Identifies the message as a logical decoding message. +</para> +</listitem> +</varlistentry> +<varlistentry> +<term> + Int32 +</term> +<listitem> +<para> + Xid of the transaction. The XID is sent only when user has + requested streaming of in-progress transactions. +</para> +</listitem> +</varlistentry> +<varlistentry> +<term> + Int8 +</term> +<listitem> +<para> + Flags; Either 0 for no flags or 1 if the logical decoding + message is transactional. +</para> +</listitem> +</varlistentry> +<varlistentry> +<term> + Int64 +</term> +<listitem> +<para> + The LSN of the logical decoding message. +</para> +</listitem> +</varlistentry> +<varlistentry> +<term> + String +</term> +<listitem> +<para> + The prefix of the logical decoding message. +</para> +</listitem> +</varlistentry> +<varlistentry> +<term> + Byte<replaceable>n</replaceable> +</term> +<listitem> +<para> + The content of the logical decoding message. +</para> +</listitem> +</varlistentry> + +</variablelist> +</para> +</listitem> +</varlistentry> + +<varlistentry> +<term> Commit </term> <listitem> |