Skip to content

Commit 0c31414

Browse files
committed
Allow row filter hooks to see details of the changed tuple
1 parent 2a8129f commit 0c31414

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

contrib/pglogical_output/pglogical_hooks.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -188,6 +188,7 @@ call_row_filter_hook(PGLogicalOutputData *data, ReorderBufferTXN *txn,
188188
hook_args.change_type = change->action;
189189
hook_args.private_data = data->hooks.hooks_private_data;
190190
hook_args.changed_rel = rel;
191+
hook_args.change = change;
191192

192193
elog(DEBUG3, "calling pglogical row filter hook");
193194

contrib/pglogical_output/pglogical_output/hooks.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@ struct PGLogicalRowFilterArgs
4343
void *private_data;
4444
Relation changed_rel;
4545
enum ReorderBufferChangeType change_type;
46+
/* detailed row change event from logical decoding */
47+
ReorderBufferChange* change;
4648
};
4749

4850
typedef bool (*pglogical_row_filter_hook_fn)(struct PGLogicalRowFilterArgs *args);

0 commit comments

Comments
 (0)