PostgreSQL Source Code  git master
Data Structures | Typedefs | Enumerations | Functions
output_plugin.h File Reference
#include "replication/reorderbuffer.h"
Include dependency graph for output_plugin.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  OutputPluginOptions
 
struct  OutputPluginCallbacks
 

Typedefs

typedef enum OutputPluginOutputType OutputPluginOutputType
 
typedef struct OutputPluginOptions OutputPluginOptions
 
typedef void(* LogicalOutputPluginInit) (struct OutputPluginCallbacks *cb)
 
typedef void(* LogicalDecodeStartupCB) (struct LogicalDecodingContext *ctx, OutputPluginOptions *options, bool is_init)
 
typedef void(* LogicalDecodeBeginCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
 
typedef void(* LogicalDecodeChangeCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)
 
typedef void(* LogicalDecodeTruncateCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)
 
typedef void(* LogicalDecodeCommitCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
 
typedef void(* LogicalDecodeMessageCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr message_lsn, bool transactional, const char *prefix, Size message_size, const char *message)
 
typedef bool(* LogicalDecodeFilterByOriginCB) (struct LogicalDecodingContext *ctx, RepOriginId origin_id)
 
typedef void(* LogicalDecodeShutdownCB) (struct LogicalDecodingContext *ctx)
 
typedef bool(* LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx, TransactionId xid, const char *gid)
 
typedef void(* LogicalDecodeBeginPrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
 
typedef void(* LogicalDecodePrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)
 
typedef void(* LogicalDecodeCommitPreparedCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
 
typedef void(* LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_end_lsn, TimestampTz prepare_time)
 
typedef void(* LogicalDecodeStreamStartCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
 
typedef void(* LogicalDecodeStreamStopCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
 
typedef void(* LogicalDecodeStreamAbortCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr abort_lsn)
 
typedef void(* LogicalDecodeStreamPrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)
 
typedef void(* LogicalDecodeStreamCommitCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
 
typedef void(* LogicalDecodeStreamChangeCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)
 
typedef void(* LogicalDecodeStreamMessageCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr message_lsn, bool transactional, const char *prefix, Size message_size, const char *message)
 
typedef void(* LogicalDecodeStreamTruncateCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)
 
typedef struct OutputPluginCallbacks OutputPluginCallbacks
 

Enumerations

enum  OutputPluginOutputType { OUTPUT_PLUGIN_BINARY_OUTPUT , OUTPUT_PLUGIN_TEXTUAL_OUTPUT }
 

Functions

PGDLLEXPORT void _PG_output_plugin_init (struct OutputPluginCallbacks *cb)
 
void OutputPluginPrepareWrite (struct LogicalDecodingContext *ctx, bool last_write)
 
void OutputPluginWrite (struct LogicalDecodingContext *ctx, bool last_write)
 
void OutputPluginUpdateProgress (struct LogicalDecodingContext *ctx, bool skipped_xact)
 

Typedef Documentation

◆ LogicalDecodeBeginCB

typedef void(* LogicalDecodeBeginCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)

Definition at line 55 of file output_plugin.h.

◆ LogicalDecodeBeginPrepareCB

typedef void(* LogicalDecodeBeginPrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)

Definition at line 117 of file output_plugin.h.

◆ LogicalDecodeChangeCB

typedef void(* LogicalDecodeChangeCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)

Definition at line 61 of file output_plugin.h.

◆ LogicalDecodeCommitCB

typedef void(* LogicalDecodeCommitCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)

Definition at line 78 of file output_plugin.h.

◆ LogicalDecodeCommitPreparedCB

typedef void(* LogicalDecodeCommitPreparedCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)

Definition at line 131 of file output_plugin.h.

◆ LogicalDecodeFilterByOriginCB

typedef bool(* LogicalDecodeFilterByOriginCB) (struct LogicalDecodingContext *ctx, RepOriginId origin_id)

Definition at line 96 of file output_plugin.h.

◆ LogicalDecodeFilterPrepareCB

typedef bool(* LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx, TransactionId xid, const char *gid)

Definition at line 110 of file output_plugin.h.

◆ LogicalDecodeMessageCB

typedef void(* LogicalDecodeMessageCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr message_lsn, bool transactional, const char *prefix, Size message_size, const char *message)

Definition at line 85 of file output_plugin.h.

◆ LogicalDecodePrepareCB

typedef void(* LogicalDecodePrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)

Definition at line 124 of file output_plugin.h.

◆ LogicalDecodeRollbackPreparedCB

typedef void(* LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_end_lsn, TimestampTz prepare_time)

Definition at line 138 of file output_plugin.h.

◆ LogicalDecodeShutdownCB

typedef void(* LogicalDecodeShutdownCB) (struct LogicalDecodingContext *ctx)

Definition at line 102 of file output_plugin.h.

◆ LogicalDecodeStartupCB

typedef void(* LogicalDecodeStartupCB) (struct LogicalDecodingContext *ctx, OutputPluginOptions *options, bool is_init)

Definition at line 47 of file output_plugin.h.

◆ LogicalDecodeStreamAbortCB

typedef void(* LogicalDecodeStreamAbortCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr abort_lsn)

Definition at line 164 of file output_plugin.h.

◆ LogicalDecodeStreamChangeCB

typedef void(* LogicalDecodeStreamChangeCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)

Definition at line 187 of file output_plugin.h.

◆ LogicalDecodeStreamCommitCB

typedef void(* LogicalDecodeStreamCommitCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)

Definition at line 180 of file output_plugin.h.

◆ LogicalDecodeStreamMessageCB

typedef void(* LogicalDecodeStreamMessageCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr message_lsn, bool transactional, const char *prefix, Size message_size, const char *message)

Definition at line 196 of file output_plugin.h.

◆ LogicalDecodeStreamPrepareCB

typedef void(* LogicalDecodeStreamPrepareCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)

Definition at line 172 of file output_plugin.h.

◆ LogicalDecodeStreamStartCB

typedef void(* LogicalDecodeStreamStartCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)

Definition at line 149 of file output_plugin.h.

◆ LogicalDecodeStreamStopCB

typedef void(* LogicalDecodeStreamStopCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn)

Definition at line 157 of file output_plugin.h.

◆ LogicalDecodeStreamTruncateCB

typedef void(* LogicalDecodeStreamTruncateCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)

Definition at line 207 of file output_plugin.h.

◆ LogicalDecodeTruncateCB

typedef void(* LogicalDecodeTruncateCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)

Definition at line 69 of file output_plugin.h.

◆ LogicalOutputPluginInit

typedef void(* LogicalOutputPluginInit) (struct OutputPluginCallbacks *cb)

Definition at line 36 of file output_plugin.h.

◆ OutputPluginCallbacks

typedef struct OutputPluginCallbacks OutputPluginCallbacks

◆ OutputPluginOptions

typedef struct OutputPluginOptions OutputPluginOptions

◆ OutputPluginOutputType

typedef enum OutputPluginOutputType OutputPluginOutputType

Enumeration Type Documentation

◆ OutputPluginOutputType

enum OutputPluginOutputType
Enumerator
OUTPUT_PLUGIN_BINARY_OUTPUT 
OUTPUT_PLUGIN_TEXTUAL_OUTPUT 

Definition at line 17 of file output_plugin.h.

18 {
19  OUTPUT_PLUGIN_BINARY_OUTPUT,
20  OUTPUT_PLUGIN_TEXTUAL_OUTPUT
21 } OutputPluginOutputType;
OutputPluginOutputType
OutputPluginOutputType
Definition: output_plugin.h:18
OUTPUT_PLUGIN_BINARY_OUTPUT
@ OUTPUT_PLUGIN_BINARY_OUTPUT
Definition: output_plugin.h:19
OUTPUT_PLUGIN_TEXTUAL_OUTPUT
@ OUTPUT_PLUGIN_TEXTUAL_OUTPUT
Definition: output_plugin.h:20

Function Documentation

◆ _PG_output_plugin_init()

PGDLLEXPORT void _PG_output_plugin_init ( struct OutputPluginCallbacks *  cb)

Definition at line 128 of file test_decoding.c.

129 {
130  cb->startup_cb = pg_decode_startup;
131  cb->begin_cb = pg_decode_begin_txn;
132  cb->change_cb = pg_decode_change;
133  cb->truncate_cb = pg_decode_truncate;
134  cb->commit_cb = pg_decode_commit_txn;
135  cb->filter_by_origin_cb = pg_decode_filter;
136  cb->shutdown_cb = pg_decode_shutdown;
137  cb->message_cb = pg_decode_message;
138  cb->filter_prepare_cb = pg_decode_filter_prepare;
139  cb->begin_prepare_cb = pg_decode_begin_prepare_txn;
140  cb->prepare_cb = pg_decode_prepare_txn;
141  cb->commit_prepared_cb = pg_decode_commit_prepared_txn;
142  cb->rollback_prepared_cb = pg_decode_rollback_prepared_txn;
143  cb->stream_start_cb = pg_decode_stream_start;
144  cb->stream_stop_cb = pg_decode_stream_stop;
145  cb->stream_abort_cb = pg_decode_stream_abort;
146  cb->stream_prepare_cb = pg_decode_stream_prepare;
147  cb->stream_commit_cb = pg_decode_stream_commit;
148  cb->stream_change_cb = pg_decode_stream_change;
149  cb->stream_message_cb = pg_decode_stream_message;
150  cb->stream_truncate_cb = pg_decode_stream_truncate;
151 }
OutputPluginCallbacks::stream_change_cb
LogicalDecodeStreamChangeCB stream_change_cb
Definition: output_plugin.h:240
OutputPluginCallbacks::message_cb
LogicalDecodeMessageCB message_cb
Definition: output_plugin.h:223
OutputPluginCallbacks::stream_truncate_cb
LogicalDecodeStreamTruncateCB stream_truncate_cb
Definition: output_plugin.h:242
OutputPluginCallbacks::stream_message_cb
LogicalDecodeStreamMessageCB stream_message_cb
Definition: output_plugin.h:241
OutputPluginCallbacks::filter_prepare_cb
LogicalDecodeFilterPrepareCB filter_prepare_cb
Definition: output_plugin.h:228
OutputPluginCallbacks::filter_by_origin_cb
LogicalDecodeFilterByOriginCB filter_by_origin_cb
Definition: output_plugin.h:224
OutputPluginCallbacks::truncate_cb
LogicalDecodeTruncateCB truncate_cb
Definition: output_plugin.h:221
OutputPluginCallbacks::stream_stop_cb
LogicalDecodeStreamStopCB stream_stop_cb
Definition: output_plugin.h:236
OutputPluginCallbacks::stream_commit_cb
LogicalDecodeStreamCommitCB stream_commit_cb
Definition: output_plugin.h:239
OutputPluginCallbacks::rollback_prepared_cb
LogicalDecodeRollbackPreparedCB rollback_prepared_cb
Definition: output_plugin.h:232
OutputPluginCallbacks::stream_prepare_cb
LogicalDecodeStreamPrepareCB stream_prepare_cb
Definition: output_plugin.h:238
OutputPluginCallbacks::commit_prepared_cb
LogicalDecodeCommitPreparedCB commit_prepared_cb
Definition: output_plugin.h:231
OutputPluginCallbacks::stream_start_cb
LogicalDecodeStreamStartCB stream_start_cb
Definition: output_plugin.h:235
OutputPluginCallbacks::prepare_cb
LogicalDecodePrepareCB prepare_cb
Definition: output_plugin.h:230
OutputPluginCallbacks::startup_cb
LogicalDecodeStartupCB startup_cb
Definition: output_plugin.h:218
OutputPluginCallbacks::commit_cb
LogicalDecodeCommitCB commit_cb
Definition: output_plugin.h:222
OutputPluginCallbacks::begin_cb
LogicalDecodeBeginCB begin_cb
Definition: output_plugin.h:219
OutputPluginCallbacks::stream_abort_cb
LogicalDecodeStreamAbortCB stream_abort_cb
Definition: output_plugin.h:237
OutputPluginCallbacks::begin_prepare_cb
LogicalDecodeBeginPrepareCB begin_prepare_cb
Definition: output_plugin.h:229
OutputPluginCallbacks::change_cb
LogicalDecodeChangeCB change_cb
Definition: output_plugin.h:220
OutputPluginCallbacks::shutdown_cb
LogicalDecodeShutdownCB shutdown_cb
Definition: output_plugin.h:225
pg_decode_prepare_txn
static void pg_decode_prepare_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)
Definition: test_decoding.c:368
pg_decode_stream_start
static void pg_decode_stream_start(LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
Definition: test_decoding.c:754
pg_decode_rollback_prepared_txn
static void pg_decode_rollback_prepared_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_end_lsn, TimestampTz prepare_time)
Definition: test_decoding.c:420
pg_decode_commit_prepared_txn
static void pg_decode_commit_prepared_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
Definition: test_decoding.c:398
pg_decode_begin_txn
static void pg_decode_begin_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
Definition: test_decoding.c:287
pg_decode_change
static void pg_decode_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)
Definition: test_decoding.c:600
pg_decode_begin_prepare_txn
static void pg_decode_begin_prepare_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
Definition: test_decoding.c:347
pg_decode_commit_txn
static void pg_decode_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
Definition: test_decoding.c:319
pg_decode_stream_change
static void pg_decode_stream_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change)
Definition: test_decoding.c:902
pg_decode_message
static void pg_decode_message(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr lsn, bool transactional, const char *prefix, Size sz, const char *message)
Definition: test_decoding.c:742
pg_decode_shutdown
static void pg_decode_shutdown(LogicalDecodingContext *ctx)
Definition: test_decoding.c:277
pg_decode_stream_abort
static void pg_decode_stream_abort(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr abort_lsn)
Definition: test_decoding.c:807
pg_decode_stream_prepare
static void pg_decode_stream_prepare(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr prepare_lsn)
Definition: test_decoding.c:841
pg_decode_stream_commit
static void pg_decode_stream_commit(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn)
Definition: test_decoding.c:868
pg_decode_filter
static bool pg_decode_filter(LogicalDecodingContext *ctx, RepOriginId origin_id)
Definition: test_decoding.c:460
pg_decode_filter_prepare
static bool pg_decode_filter_prepare(LogicalDecodingContext *ctx, TransactionId xid, const char *gid)
Definition: test_decoding.c:450
pg_decode_stream_truncate
static void pg_decode_stream_truncate(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)
Definition: test_decoding.c:957
pg_decode_truncate
static void pg_decode_truncate(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, int nrelations, Relation relations[], ReorderBufferChange *change)
Definition: test_decoding.c:687
pg_decode_startup
static void pg_decode_startup(LogicalDecodingContext *ctx, OutputPluginOptions *opt, bool is_init)
Definition: test_decoding.c:156
pg_decode_stream_stop
static void pg_decode_stream_stop(LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
Definition: test_decoding.c:789
pg_decode_stream_message
static void pg_decode_stream_message(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr lsn, bool transactional, const char *prefix, Size sz, const char *message)
Definition: test_decoding.c:931

References OutputPluginCallbacks::begin_cb, OutputPluginCallbacks::begin_prepare_cb, OutputPluginCallbacks::change_cb, OutputPluginCallbacks::commit_cb, OutputPluginCallbacks::commit_prepared_cb, OutputPluginCallbacks::filter_by_origin_cb, OutputPluginCallbacks::filter_prepare_cb, OutputPluginCallbacks::message_cb, pg_decode_begin_prepare_txn(), pg_decode_begin_txn(), pg_decode_change(), pg_decode_commit_prepared_txn(), pg_decode_commit_txn(), pg_decode_filter(), pg_decode_filter_prepare(), pg_decode_message(), pg_decode_prepare_txn(), pg_decode_rollback_prepared_txn(), pg_decode_shutdown(), pg_decode_startup(), pg_decode_stream_abort(), pg_decode_stream_change(), pg_decode_stream_commit(), pg_decode_stream_message(), pg_decode_stream_prepare(), pg_decode_stream_start(), pg_decode_stream_stop(), pg_decode_stream_truncate(), pg_decode_truncate(), pgoutput_begin_prepare_txn(), pgoutput_begin_txn(), pgoutput_change(), pgoutput_commit_prepared_txn(), pgoutput_commit_txn(), pgoutput_message(), pgoutput_origin_filter(), pgoutput_prepare_txn(), pgoutput_rollback_prepared_txn(), pgoutput_shutdown(), pgoutput_startup(), pgoutput_stream_abort(), pgoutput_stream_commit(), pgoutput_stream_prepare_txn(), pgoutput_stream_start(), pgoutput_stream_stop(), pgoutput_truncate(), OutputPluginCallbacks::prepare_cb, OutputPluginCallbacks::rollback_prepared_cb, OutputPluginCallbacks::shutdown_cb, OutputPluginCallbacks::startup_cb, OutputPluginCallbacks::stream_abort_cb, OutputPluginCallbacks::stream_change_cb, OutputPluginCallbacks::stream_commit_cb, OutputPluginCallbacks::stream_message_cb, OutputPluginCallbacks::stream_prepare_cb, OutputPluginCallbacks::stream_start_cb, OutputPluginCallbacks::stream_stop_cb, OutputPluginCallbacks::stream_truncate_cb, and OutputPluginCallbacks::truncate_cb.

◆ OutputPluginPrepareWrite()

void OutputPluginPrepareWrite ( struct LogicalDecodingContext *  ctx,
bool  last_write 
)

Definition at line 662 of file logical.c.

663 {
664  if (!ctx->accept_writes)
665  elog(ERROR, "writes are only accepted in commit, begin and change callbacks");
666 
667  ctx->prepare_write(ctx, ctx->write_location, ctx->write_xid, last_write);
668  ctx->prepared_write = true;
669 }
ERROR
#define ERROR
Definition: elog.h:39
LogicalDecodingContext::write_location
XLogRecPtr write_location
Definition: logical.h:108
LogicalDecodingContext::prepare_write
LogicalOutputPluginWriterPrepareWrite prepare_write
Definition: logical.h:64
LogicalDecodingContext::write_xid
TransactionId write_xid
Definition: logical.h:109

References LogicalDecodingContext::accept_writes, elog(), ERROR, LogicalDecodingContext::prepare_write, LogicalDecodingContext::prepared_write, LogicalDecodingContext::write_location, and LogicalDecodingContext::write_xid.

Referenced by pg_decode_change(), pg_decode_commit_prepared_txn(), pg_decode_commit_txn(), pg_decode_message(), pg_decode_prepare_txn(), pg_decode_rollback_prepared_txn(), pg_decode_stream_abort(), pg_decode_stream_change(), pg_decode_stream_commit(), pg_decode_stream_message(), pg_decode_stream_prepare(), pg_decode_stream_stop(), pg_decode_stream_truncate(), pg_decode_truncate(), pg_output_begin(), pg_output_stream_start(), pgoutput_begin_prepare_txn(), pgoutput_change(), pgoutput_commit_prepared_txn(), pgoutput_commit_txn(), pgoutput_message(), pgoutput_prepare_txn(), pgoutput_rollback_prepared_txn(), pgoutput_send_begin(), pgoutput_stream_abort(), pgoutput_stream_commit(), pgoutput_stream_prepare_txn(), pgoutput_stream_start(), pgoutput_stream_stop(), pgoutput_truncate(), send_relation_and_attrs(), and send_repl_origin().

◆ OutputPluginUpdateProgress()

void OutputPluginUpdateProgress ( struct LogicalDecodingContext *  ctx,
bool  skipped_xact 
)

Definition at line 688 of file logical.c.

690 {
691  if (!ctx->update_progress)
692  return;
693 
694  ctx->update_progress(ctx, ctx->write_location, ctx->write_xid,
695  skipped_xact);
696 }
LogicalDecodingContext::update_progress
LogicalOutputPluginWriterUpdateProgress update_progress
Definition: logical.h:66

References LogicalDecodingContext::update_progress, LogicalDecodingContext::write_location, and LogicalDecodingContext::write_xid.

Referenced by pgoutput_commit_prepared_txn(), pgoutput_commit_txn(), pgoutput_prepare_txn(), pgoutput_rollback_prepared_txn(), pgoutput_stream_commit(), pgoutput_stream_prepare_txn(), and update_progress_txn_cb_wrapper().

◆ OutputPluginWrite()

void OutputPluginWrite ( struct LogicalDecodingContext *  ctx,
bool  last_write 
)

Definition at line 675 of file logical.c.

676 {
677  if (!ctx->prepared_write)
678  elog(ERROR, "OutputPluginPrepareWrite needs to be called before OutputPluginWrite");
679 
680  ctx->write(ctx, ctx->write_location, ctx->write_xid, last_write);
681  ctx->prepared_write = false;
682 }
LogicalDecodingContext::write
LogicalOutputPluginWriterWrite write
Definition: logical.h:65

References elog(), ERROR, LogicalDecodingContext::prepared_write, LogicalDecodingContext::write, LogicalDecodingContext::write_location, and LogicalDecodingContext::write_xid.

Referenced by pg_decode_change(), pg_decode_commit_prepared_txn(), pg_decode_commit_txn(), pg_decode_message(), pg_decode_prepare_txn(), pg_decode_rollback_prepared_txn(), pg_decode_stream_abort(), pg_decode_stream_change(), pg_decode_stream_commit(), pg_decode_stream_message(), pg_decode_stream_prepare(), pg_decode_stream_stop(), pg_decode_stream_truncate(), pg_decode_truncate(), pg_output_begin(), pg_output_stream_start(), pgoutput_begin_prepare_txn(), pgoutput_change(), pgoutput_commit_prepared_txn(), pgoutput_commit_txn(), pgoutput_message(), pgoutput_prepare_txn(), pgoutput_rollback_prepared_txn(), pgoutput_send_begin(), pgoutput_stream_abort(), pgoutput_stream_commit(), pgoutput_stream_prepare_txn(), pgoutput_stream_start(), pgoutput_stream_stop(), pgoutput_truncate(), send_relation_and_attrs(), and send_repl_origin().