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 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 90 of file logical.h.

Referenced by begin_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), filter_by_origin_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), shutdown_cb_wrapper(), startup_cb_wrapper(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_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(), change_cb_wrapper(), commit_cb_wrapper(), CreateDecodingContext(), CreateInitDecodingContext(), filter_by_origin_cb_wrapper(), FilterByOrigin(), FreeDecodingContext(), message_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_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_startup(), pgoutput_startup(), and StartupDecodingContext().

◆ fast_forward

bool LogicalDecodingContext::fast_forward

Definition at line 50 of file logical.h.

Referenced by begin_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), DecodeCommit(), DecodeHeap2Op(), DecodeHeapOp(), DecodeLogicalMsgOp(), DecodeXactOp(), filter_by_origin_cb_wrapper(), message_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_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_txn(), pg_decode_message(), pg_decode_stream_abort(), pg_decode_stream_change(), pg_decode_stream_commit(), pg_decode_stream_message(), 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_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 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_txn(), pg_decode_change(), pg_decode_commit_txn(), pg_decode_filter(), pg_decode_shutdown(), pg_decode_startup(), pg_decode_stream_abort(), pg_decode_stream_change(), pg_decode_stream_commit(), pg_decode_stream_start(), pg_decode_stream_stop(), pg_decode_stream_truncate(), pg_decode_truncate(), pgoutput_change(), 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 91 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(), DecodeSpecConfirm(), DecodeStandbyOp(), DecodeTruncate(), DecodeUpdate(), DecodeXactOp(), DecodeXLogOp(), FreeDecodingContext(), LogicalDecodingProcessRecord(), and StartupDecodingContext().

◆ slot

ReplicationSlot* LogicalDecodingContext::slot

Definition at line 38 of file logical.h.

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

◆ snapshot_builder

struct SnapBuild* LogicalDecodingContext::snapshot_builder

Definition at line 43 of file logical.h.

Referenced by CreateReplicationSlot(), DecodeCommit(), DecodeHeap2Op(), DecodeHeapOp(), DecodeLogicalMsgOp(), DecodeStandbyOp(), 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_start_cb_wrapper(), stream_stop_cb_wrapper(), and stream_truncate_cb_wrapper().

◆ 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 92 of file logical.h.

Referenced by begin_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), OutputPluginUpdateProgress(), OutputPluginWrite(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_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 93 of file logical.h.

Referenced by begin_cb_wrapper(), change_cb_wrapper(), commit_cb_wrapper(), message_cb_wrapper(), OutputPluginPrepareWrite(), OutputPluginUpdateProgress(), OutputPluginWrite(), stream_abort_cb_wrapper(), stream_change_cb_wrapper(), stream_commit_cb_wrapper(), stream_message_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: