database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed b8cf745 from https://gitee.com/chenxiaobin19/openGauss-server/pulls/3129

Browse Source 
add include-originid option for logical decode
This commit is contained in:
chenxiaobin19
2023-03-13 21:40:11 +08:00
committed by chenxiaobin
parent ee6e76c0cd
commit 7ec615deb2
10 changed files with 36 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/include/replication/logical.h
View File

@ -134,6 +134,7 @@ typedef struct {
ParallelDecodeChangeCB decode_change;
List *tableWhiteList;
int parallel_queue_size;
bool include_originid;
} ParallelDecodeOption;
typedef struct {
@ -151,6 +152,7 @@ typedef struct {
int max_txn_in_memory;
int max_reorderbuffer_in_memory;
List *tableWhiteList;
bool include_originid;
} PluginTestDecodingData;
typedef struct ParallelLogicalDecodingContext {

2
src/include/replication/parallel_reorderbuffer.h
View File

@ -53,6 +53,7 @@ typedef struct logicalLog {
int nsubxacts;
TransactionId *subXids;
TimestampTz commitTime;
RepOriginId origin_id;
HTAB* toast_hash;
ParallelReorderBufferTXN *txn;
logicalLog *freeNext;
@ -148,6 +149,7 @@ typedef struct ParallelReorderBufferChange {
TransactionId * subXids;
dlist_node node;
TimestampTz commitTime;
RepOriginId origin_id;
} ParallelReorderBufferChange;
typedef struct ParallelReorderBufferTXN {