PostgreSQL Source Code  git master
Data Fields
LogicalDecodingContext Struct Reference

#include <logical.h>

Data Fields

MemoryContext context
 
ReplicationSlot * slot
 
XLogReaderState * reader
 
struct ReorderBuffer * reorder
 
struct SnapBuild * snapshot_builder
 
bool fast_forward
 
OutputPluginCallbacks callbacks
 
OutputPluginOptions options
 
List * output_plugin_options
 
LogicalOutputPluginWriterPrepareWrite prepare_write
 
LogicalOutputPluginWriterWrite write
 
LogicalOutputPluginWriterUpdateProgress update_progress
 
StringInfo out
 
void * output_plugin_private
 
void * output_writer_private
 
bool streaming
 
bool twophase
 
bool twophase_opt_given
 
bool accept_writes
 
bool prepared_write
 
XLogRecPtr write_location
 
TransactionId write_xid
 
bool end_xact
 
bool processing_required
 

Detailed Description

Definition at line 33 of file logical.h.

Field Documentation

◆ accept_writes

bool LogicalDecodingContext::accept_writes

Definition at line 106 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), filter_by_origin_cb_wrapper(), filter_prepare_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), shutdown_cb_wrapper(), startup_cb_wrapper(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), truncate_cb_wrapper(), and update_progress_txn_cb_wrapper().

◆ callbacks

OutputPluginCallbacks LogicalDecodingContext::callbacks

Definition at line 53 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), CreateDecodingContext(), CreateInitDecodingContext(), filter_by_origin_cb_wrapper(), filter_prepare_cb_wrapper(), FilterByOrigin(), FilterPrepare(), FreeDecodingContext(), message_cb_wrapper(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), shutdown_cb_wrapper(), startup_cb_wrapper(), StartupDecodingContext(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), and truncate_cb_wrapper().

◆ context

MemoryContext LogicalDecodingContext::context

Definition at line 36 of file logical.h.

Referenced by CreateDecodingContext(), CreateInitDecodingContext(), FreeDecodingContext(), pg_decode_begin_prepare_txn(), pg_decode_begin_txn(), pg_decode_startup(), pg_decode_stream_start(), pgoutput_begin_txn(), pgoutput_startup(), and StartupDecodingContext().

◆ end_xact

bool LogicalDecodingContext::end_xact

Definition at line 111 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), filter_by_origin_cb_wrapper(), filter_prepare_cb_wrapper(), message_cb_wrapper(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), shutdown_cb_wrapper(), startup_cb_wrapper(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), truncate_cb_wrapper(), update_progress_txn_cb_wrapper(), and WalSndUpdateProgress().

◆ fast_forward

bool LogicalDecodingContext::fast_forward

Definition at line 51 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), DecodeTXNNeedSkip(), filter_by_origin_cb_wrapper(), filter_prepare_cb_wrapper(), heap2_decode(), heap_decode(), logicalmsg_decode(), message_cb_wrapper(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), shutdown_cb_wrapper(), startup_cb_wrapper(), StartupDecodingContext(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), truncate_cb_wrapper(), update_progress_txn_cb_wrapper(), and xact_decode().

◆ options

OutputPluginOptions LogicalDecodingContext::options

Definition at line 54 of file logical.h.

Referenced by CreateDecodingContext(), and CreateInitDecodingContext().

◆ out

StringInfo LogicalDecodingContext::out

Definition at line 71 of file logical.h.

Referenced by LogicalOutputPrepareWrite(), LogicalOutputWrite(), 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(), send_repl_origin(), StartupDecodingContext(), WalSndPrepareWrite(), and WalSndWriteData().

◆ output_plugin_options

List* LogicalDecodingContext::output_plugin_options

Definition at line 59 of file logical.h.

Referenced by pg_decode_startup(), pgoutput_startup(), and StartupDecodingContext().

◆ output_plugin_private

void* LogicalDecodingContext::output_plugin_private

Definition at line 76 of file logical.h.

Referenced by maybe_send_schema(), 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_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_change(), pgoutput_message(), pgoutput_origin_filter(), pgoutput_startup(), pgoutput_stream_abort(), pgoutput_stream_commit(), pgoutput_stream_start(), pgoutput_stream_stop(), and pgoutput_truncate().

◆ output_writer_private

void* LogicalDecodingContext::output_writer_private

Definition at line 81 of file logical.h.

Referenced by LogicalOutputWrite().

◆ prepare_write

LogicalOutputPluginWriterPrepareWrite LogicalDecodingContext::prepare_write

Definition at line 64 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and StartupDecodingContext().

◆ prepared_write

bool LogicalDecodingContext::prepared_write

Definition at line 107 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and OutputPluginWrite().

◆ processing_required

bool LogicalDecodingContext::processing_required

Definition at line 114 of file logical.h.

Referenced by DecodeTXNNeedSkip(), logicalmsg_decode(), and LogicalReplicationSlotHasPendingWal().

◆ reader

XLogReaderState* LogicalDecodingContext::reader

Definition at line 42 of file logical.h.

Referenced by AssertTXNLsnOrder(), DecodingContextFindStartpoint(), FreeDecodingContext(), LogicalDecodingProcessRecord(), LogicalReplicationSlotHasPendingWal(), pg_logical_replication_slot_advance(), ReorderBufferCanStartStreaming(), StartLogicalReplication(), StartupDecodingContext(), and XLogSendLogical().

◆ reorder

struct ReorderBuffer* LogicalDecodingContext::reorder

Definition at line 43 of file logical.h.

Referenced by CreateDecodingContext(), CreateInitDecodingContext(), DecodeAbort(), DecodeCommit(), DecodeDelete(), DecodeInsert(), DecodeMultiInsert(), DecodePrepare(), DecodeSpecConfirm(), DecodeTruncate(), DecodeUpdate(), FreeDecodingContext(), heap2_decode(), heap_decode(), LogicalDecodingProcessRecord(), logicalmsg_decode(), standby_decode(), StartupDecodingContext(), UpdateDecodingStats(), xact_decode(), and xlog_decode().

◆ slot

ReplicationSlot* LogicalDecodingContext::slot

Definition at line 39 of file logical.h.

Referenced by DecodeDelete(), DecodeInsert(), DecodeMultiInsert(), DecodeSpecConfirm(), DecodeTruncate(), DecodeTXNNeedSkip(), DecodeUpdate(), DecodingContextFindStartpoint(), logicalmsg_decode(), StartupDecodingContext(), and UpdateDecodingStats().

◆ snapshot_builder

struct SnapBuild* LogicalDecodingContext::snapshot_builder

Definition at line 44 of file logical.h.

Referenced by AssertTXNLsnOrder(), CreateDecodingContext(), CreateReplicationSlot(), DecodeCommit(), DecodePrepare(), DecodeTXNNeedSkip(), DecodingContextReady(), FreeDecodingContext(), heap2_decode(), heap_decode(), logicalmsg_decode(), ReorderBufferCanStartStreaming(), standby_decode(), StartupDecodingContext(), xact_decode(), and xlog_decode().

◆ streaming

bool LogicalDecodingContext::streaming

Definition at line 86 of file logical.h.

Referenced by pg_decode_startup(), pgoutput_startup(), ReorderBufferCanStream(), StartupDecodingContext(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), and stream_truncate_cb_wrapper().

◆ twophase

bool LogicalDecodingContext::twophase

Definition at line 91 of file logical.h.

Referenced by begin_prepare_cb_wrapper(), commit_prepared_cb_wrapper(), CreateDecodingContext(), CreateInitDecodingContext(), FilterPrepare(), pgoutput_startup(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), StartupDecodingContext(), and stream_prepare_cb_wrapper().

◆ twophase_opt_given

bool LogicalDecodingContext::twophase_opt_given

Definition at line 101 of file logical.h.

Referenced by CreateDecodingContext(), and pgoutput_startup().

◆ update_progress

LogicalOutputPluginWriterUpdateProgress LogicalDecodingContext::update_progress

Definition at line 66 of file logical.h.

Referenced by OutputPluginUpdateProgress(), and StartupDecodingContext().

◆ write

LogicalOutputPluginWriterWrite LogicalDecodingContext::write

Definition at line 65 of file logical.h.

Referenced by OutputPluginWrite(), and StartupDecodingContext().

◆ write_location

XLogRecPtr LogicalDecodingContext::write_location

Definition at line 108 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), OutputPluginUpdateProgress(), OutputPluginWrite(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), truncate_cb_wrapper(), and update_progress_txn_cb_wrapper().

◆ write_xid

TransactionId LogicalDecodingContext::write_xid

Definition at line 109 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), OutputPluginUpdateProgress(), OutputPluginWrite(), prepare_cb_wrapper(), rollback_prepared_cb_wrapper(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_cb_wrapper(), stream_prepare_cb_wrapper(), stream_start_cb_wrapper(), stream_stop_cb_wrapper(), stream_truncate_cb_wrapper(), truncate_cb_wrapper(), and update_progress_txn_cb_wrapper().

The documentation for this struct was generated from the following file: