diff options
Diffstat (limited to 'src/include/replication/logical.h')
| -rw-r--r-- | src/include/replication/logical.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/include/replication/logical.h b/src/include/replication/logical.h index 5f49554ea05..dffc0d15648 100644 --- a/src/include/replication/logical.h +++ b/src/include/replication/logical.h @@ -109,6 +109,9 @@ typedef struct LogicalDecodingContext TransactionId write_xid; /* Are we processing the end LSN of a transaction? */ bool end_xact; + + /* Do we need to process any change in fast_forward mode? */ + bool processing_required; } LogicalDecodingContext; @@ -145,4 +148,6 @@ extern bool filter_by_origin_cb_wrapper(LogicalDecodingContext *ctx, RepOriginId extern void ResetLogicalStreamingState(void); extern void UpdateDecodingStats(LogicalDecodingContext *ctx); +extern bool LogicalReplicationSlotHasPendingWal(XLogRecPtr end_of_wal); + #endif |