belong to the same transaction. Similarly, all messages between a pair of
Begin Prepare and Prepare messages belong to the same transaction.
It also sends changes of large in-progress transactions between a pair of
- Stream Start and Stream Stop messages. The last stream of such a transaction
+ Stream Start and Stream Stop messages. The last stream of such a transaction
contains a Stream Commit or Stream Abort message.
Logical Replication Message Formats
-This section describes the detailed format of each logical replication message.
-These messages are returned either by the replication slot SQL interface or are
-sent by a walsender. In case of a walsender they are encapsulated inside the replication
-protocol WAL messages as described in
-and generally obey same message flow as physical replication.
+This section describes the detailed format of each logical replication
+message. These messages are either returned by the replication slot SQL
+interface or are sent by a walsender. In the case of a walsender they are
+encapsulated inside replication protocol WAL messages as described in
+, and generally obey the same message
+flow as physical replication.
- Int64
+ Int64 (XLogRecPtr)
- Int64
+ Int64 (TimestampTz)
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (TransactionId)
- Int64
+ Int64 (XLogRecPtr)
- Int8
+ Int8(0)
- Flags; currently unused (must be 0).
+ Flags; currently unused.
- Int64
+ Int64 (XLogRecPtr)
- Int64
+ Int64 (XLogRecPtr)
- Int64
+ Int64 (TimestampTz)
- Int64
+ Int64 (XLogRecPtr)
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the relation.
+ OID of the relation.
- Int32
+ Int32 (Oid)
- ID of the column's data type.
+ OID of the column's data type.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the data type.
+ OID of the data type.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the relation corresponding to the ID in the relation
+ OID of the relation corresponding to the ID in the relation
message.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the relation corresponding to the ID in the relation
+ OID of the relation corresponding to the ID in the relation
message.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the relation corresponding to the ID in the relation
+ OID of the relation corresponding to the ID in the relation
message.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (Oid)
- ID of the relation corresponding to the ID in the relation
+ OID of the relation corresponding to the ID in the relation
message. This field is repeated for each relation.
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (TransactionId)
- Int8
+ Int8(0)
- Flags; currently unused (must be 0).
+ Flags; currently unused.
- Int64
+ Int64 (XLogRecPtr)
- Int64
+ Int64 (XLogRecPtr)
- Int64
+ Int64 (TimestampTz)
- Int32
+ Int32 (TransactionId)
- Int32
+ Int32 (TransactionId)
-Int64
+
+ Int64 (XLogRecPtr)
+
The LSN of the prepare.
-Int64
+
+ Int64 (XLogRecPtr)
+
The end LSN of the prepared transaction.
-Int64
+
+ Int64 (TimestampTz)
+
Prepare timestamp of the transaction. The value is in number
of microseconds since PostgreSQL epoch (2000-01-01).
-Int32
+
+ Int32 (TransactionId)
+
Xid of the transaction.
-Int8
+
+ Int8(0)
+
- Flags; currently unused (must be 0).
+ Flags; currently unused.
-Int64
+
+ Int64 (XLogRecPtr)
+
The LSN of the prepare.
-Int64
+
+ Int64 (XLogRecPtr)
+
The end LSN of the prepared transaction.
-Int64
+
+ Int64 (TimestampTz)
+
Prepare timestamp of the transaction. The value is in number
of microseconds since PostgreSQL epoch (2000-01-01).
-Int32
+
+ Int32 (TransactionId)
+
Xid of the transaction.
-Int8
+
+ Int8(0)
+
- Flags; currently unused (must be 0).
+ Flags; currently unused.
-Int64
+
+ Int64 (XLogRecPtr)
+
The LSN of the commit prepared.
-Int64
+
+ Int64 (XLogRecPtr)
+
The end LSN of the commit prepared transaction.
-Int64
+
+ Int64 (TimestampTz)
+
Commit timestamp of the transaction. The value is in number
of microseconds since PostgreSQL epoch (2000-01-01).
-Int32
+
+ Int32 (TransactionId)
+
Xid of the transaction.
-Int8
+
+ Int8(0)
+
- Flags; currently unused (must be 0).
+ Flags; currently unused.
-Int64
+
+ Int64 (XLogRecPtr)
+
The end LSN of the prepared transaction.
-Int64
+
+ Int64 (XLogRecPtr)
+
The end LSN of the rollback prepared transaction.
-Int64
+
+ Int64 (TimestampTz)
+
Prepare timestamp of the transaction. The value is in number
of microseconds since PostgreSQL epoch (2000-01-01).
-Int64
+
+ Int64 (TimestampTz)
+
Rollback timestamp of the transaction. The value is in number
of microseconds since PostgreSQL epoch (2000-01-01).
-Int32
+
+ Int32 (TransactionId)
+
Xid of the transaction.