PostgreSQL Source Code  git master
Data Fields
LogicalDecodingContext Struct Reference

#include <logical.h>

Data Fields

MemoryContext context
 
ReplicationSlot * slot
 
XLogReaderState * reader
 
LogicalDecodingXLogPageReadCB page_read
 
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 accept_writes
 
bool prepared_write
 
XLogRecPtr write_location
 
TransactionId write_xid
 

Detailed Description

Definition at line 34 of file logical.h.

Field Documentation

◆ accept_writes

bool LogicalDecodingContext::accept_writes

Definition at line 98 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 55 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 37 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 53 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 56 of file logical.h.

Referenced by CreateDecodingContext(), and CreateInitDecodingContext().

◆ out

StringInfo LogicalDecodingContext::out

Definition at line 73 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_txn(), pgoutput_change(), pgoutput_commit_txn(), pgoutput_message(), pgoutput_stream_abort(), pgoutput_stream_commit(), pgoutput_stream_start(), pgoutput_stream_stop(), pgoutput_truncate(), send_relation_and_attrs(), StartupDecodingContext(), WalSndPrepareWrite(), and WalSndWriteData().

◆ output_plugin_options

List* LogicalDecodingContext::output_plugin_options

Definition at line 61 of file logical.h.

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

◆ output_plugin_private

void* LogicalDecodingContext::output_plugin_private

Definition at line 78 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 83 of file logical.h.

Referenced by LogicalOutputWrite().

◆ page_read

LogicalDecodingXLogPageReadCB LogicalDecodingContext::page_read

Definition at line 44 of file logical.h.

Referenced by DecodingContextFindStartpoint(), pg_logical_replication_slot_advance(), StartupDecodingContext(), and XLogSendLogical().

◆ prepare_write

LogicalOutputPluginWriterPrepareWrite LogicalDecodingContext::prepare_write

Definition at line 66 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and StartupDecodingContext().

◆ prepared_write

bool LogicalDecodingContext::prepared_write

Definition at line 99 of file logical.h.

Referenced by OutputPluginPrepareWrite(), and OutputPluginWrite().

◆ reader

XLogReaderState* LogicalDecodingContext::reader

Definition at line 43 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 45 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 40 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 46 of file logical.h.

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

◆ streaming

bool LogicalDecodingContext::streaming

Definition at line 88 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 93 of file logical.h.

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

◆ update_progress

LogicalOutputPluginWriterUpdateProgress LogicalDecodingContext::update_progress

Definition at line 68 of file logical.h.

Referenced by OutputPluginUpdateProgress(), and StartupDecodingContext().

◆ write

LogicalOutputPluginWriterWrite LogicalDecodingContext::write

Definition at line 67 of file logical.h.

Referenced by OutputPluginWrite(), and StartupDecodingContext().

◆ write_location

XLogRecPtr LogicalDecodingContext::write_location

Definition at line 100 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 101 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: