@@ -830,10 +830,10 @@ typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx
830
830
check if the plugin has already received this <command>PREPARE</command>
831
831
in which case it can either error out or skip the remaining changes of
832
832
the transaction.
833
- <programlisting>
834
- typedef void (*LogicalDecodeBeginPrepareCB) (struct LogicalDecodingContext *ctx,
835
- ReorderBufferTXN *txn);
836
- </programlisting>
833
+ <programlisting>
834
+ typedef void (*LogicalDecodeBeginPrepareCB) (struct LogicalDecodingContext *ctx,
835
+ ReorderBufferTXN *txn);
836
+ </programlisting>
837
837
</para>
838
838
</sect3>
839
839
@@ -847,11 +847,11 @@ typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx
847
847
rows will have been called before this, if there have been any modified
848
848
rows. The <parameter>gid</parameter> field, which is part of the
849
849
<parameter>txn</parameter> parameter, can be used in this callback.
850
- <programlisting>
851
- typedef void (*LogicalDecodePrepareCB) (struct LogicalDecodingContext *ctx,
852
- ReorderBufferTXN *txn,
853
- XLogRecPtr prepare_lsn);
854
- </programlisting>
850
+ <programlisting>
851
+ typedef void (*LogicalDecodePrepareCB) (struct LogicalDecodingContext *ctx,
852
+ ReorderBufferTXN *txn,
853
+ XLogRecPtr prepare_lsn);
854
+ </programlisting>
855
855
</para>
856
856
</sect3>
857
857
@@ -863,11 +863,11 @@ typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx
863
863
whenever a transaction <command>COMMIT PREPARED</command> has been decoded.
864
864
The <parameter>gid</parameter> field, which is part of the
865
865
<parameter>txn</parameter> parameter, can be used in this callback.
866
- <programlisting>
867
- typedef void (*LogicalDecodeCommitPreparedCB) (struct LogicalDecodingContext *ctx,
868
- ReorderBufferTXN *txn,
869
- XLogRecPtr commit_lsn);
870
- </programlisting>
866
+ <programlisting>
867
+ typedef void (*LogicalDecodeCommitPreparedCB) (struct LogicalDecodingContext *ctx,
868
+ ReorderBufferTXN *txn,
869
+ XLogRecPtr commit_lsn);
870
+ </programlisting>
871
871
</para>
872
872
</sect3>
873
873
@@ -885,12 +885,12 @@ typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx
885
885
it can apply the rollback, otherwise, it can skip the rollback operation. The
886
886
<parameter>gid</parameter> alone is not sufficient because the downstream
887
887
node can have a prepared transaction with same identifier.
888
- <programlisting>
889
- typedef void (*LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx,
890
- ReorderBufferTXN *txn,
891
- XLogRecPtr prepare_end_lsn,
892
- TimestampTz prepare_time);
893
- </programlisting>
888
+ <programlisting>
889
+ typedef void (*LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx,
890
+ ReorderBufferTXN *txn,
891
+ XLogRecPtr prepare_end_lsn,
892
+ TimestampTz prepare_time);
893
+ </programlisting>
894
894
</para>
895
895
</sect3>
896
896
0 commit comments