Lag tracking support

See lag times in pg_stat_replication.
eulerto · Mar 13, 2022 · 53b548a · 53b548a
1 parent 665173c
commit 53b548a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/wal2json.c b/wal2json.c
@@ -876,6 +876,10 @@ pg_decode_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 {
 	JsonDecodingData *data = ctx->output_plugin_private;
 
+#if PG_VERSION_NUM >= 100000
+	OutputPluginUpdateProgress(ctx);
+#endif
+
 	elog(DEBUG2, "my change counter: " UINT64_FORMAT " ; # of changes: " UINT64_FORMAT " ; # of changes in memory: " UINT64_FORMAT, data->nr_changes, txn->nentries, txn->nentries_mem);
 	elog(DEBUG2, "# of subxacts: %d", txn->nsubtxns);