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
 

Detailed Description

Definition at line 32 of file logical.h.

Field Documentation

◆ accept_writes

bool LogicalDecodingContext::accept_writes

Definition at line 105 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(), and truncate_cb_wrapper().

◆ callbacks

OutputPluginCallbacks LogicalDecodingContext::callbacks

Definition at line 52 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 35 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_startup(), and StartupDecodingContext().

◆ fast_forward

bool LogicalDecodingContext::fast_forward

Definition at line 50 of file logical.h.

Referenced by begin_cb_wrapper(), begin_prepare_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), commit_prepared_cb_wrapper(), DecodeHeap2Op(), DecodeHeapOp(), DecodeLogicalMsgOp(), DecodeTXNNeedSkip(), DecodeXactOp(), 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(), 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().

◆ options

OutputPluginOptions LogicalDecodingContext::options

Definition at line 53 of file logical.h.

Referenced by CreateDecodingContext(), and CreateInitDecodingContext().

◆ out

StringInfo LogicalDecodingContext::out

Definition at line 70 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_begin_txn(), pgoutput_change(), pgoutput_commit_prepared_txn(), pgoutput_commit_txn(), pgoutput_message(), pgoutput_prepare_txn(), pgoutput_rollback_prepared_txn(), 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 58 of file logical.h.

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

◆ output_plugin_private

void* LogicalDecodingContext::output_plugin_private

Definition at line 75 of file logical.h.

Referenced by 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_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_prepare(), pg_decode_stream_start(), pg_decode_stream_stop(), pg_decode_stream_truncate(), pg_decode_truncate(), pgoutput_change(), pgoutput_message(), pgoutput_startup(), and pgoutput_truncate().

◆ output_writer_private

void* LogicalDecodingContext::output_writer_private

Definition at line 80 of file logical.h.

Referenced by LogicalOutputWrite().

◆ prepare_write

LogicalOutputPluginWriterPrepareWrite LogicalDecodingContext::prepare_write

Definition at line 63 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and StartupDecodingContext().

◆ prepared_write

bool LogicalDecodingContext::prepared_write

Definition at line 106 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and OutputPluginWrite().

◆ reader

XLogReaderState* LogicalDecodingContext::reader

Definition at line 41 of file logical.h.

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

◆ reorder

struct ReorderBuffer* LogicalDecodingContext::reorder

Definition at line 42 of file logical.h.

Referenced by CreateDecodingContext(), CreateInitDecodingContext(), DecodeAbort(), DecodeCommit(), DecodeDelete(), DecodeHeap2Op(), DecodeHeapOp(), DecodeInsert(), DecodeLogicalMsgOp(), DecodeMultiInsert(), DecodePrepare(), DecodeSpecConfirm(), DecodeStandbyOp(), DecodeTruncate(), DecodeUpdate(), DecodeXactOp(), DecodeXLogOp(), FreeDecodingContext(), LogicalDecodingProcessRecord(), StartupDecodingContext(), and UpdateDecodingStats().

◆ slot

ReplicationSlot* LogicalDecodingContext::slot

Definition at line 38 of file logical.h.

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

◆ snapshot_builder

struct SnapBuild* LogicalDecodingContext::snapshot_builder

Definition at line 43 of file logical.h.

Referenced by CreateDecodingContext(), CreateReplicationSlot(), DecodeCommit(), DecodeHeap2Op(), DecodeHeapOp(), DecodeLogicalMsgOp(), DecodePrepare(), DecodeStandbyOp(), DecodeTXNNeedSkip(), DecodeXactOp(), DecodeXLogOp(), DecodingContextReady(), FreeDecodingContext(), ReorderBufferCanStartStreaming(), and StartupDecodingContext().

◆ streaming

bool LogicalDecodingContext::streaming

Definition at line 85 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 90 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 100 of file logical.h.

Referenced by CreateDecodingContext(), and pgoutput_startup().

◆ update_progress

LogicalOutputPluginWriterUpdateProgress LogicalDecodingContext::update_progress

Definition at line 65 of file logical.h.

Referenced by OutputPluginUpdateProgress(), and StartupDecodingContext().

◆ write

LogicalOutputPluginWriterWrite LogicalDecodingContext::write

Definition at line 64 of file logical.h.

Referenced by OutputPluginWrite(), and StartupDecodingContext().

◆ write_location

XLogRecPtr LogicalDecodingContext::write_location

Definition at line 107 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(), and truncate_cb_wrapper().

◆ write_xid

TransactionId LogicalDecodingContext::write_xid

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(), and truncate_cb_wrapper().

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