PostgreSQL Source Code
git master
|
#include <logical.h>
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().
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().
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().
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().
OutputPluginOptions LogicalDecodingContext::options |
Definition at line 56 of file logical.h.
Referenced by CreateDecodingContext(), and CreateInitDecodingContext().
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().
List* LogicalDecodingContext::output_plugin_options |
Definition at line 61 of file logical.h.
Referenced by pg_decode_startup(), pgoutput_startup(), and StartupDecodingContext().
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().
void* LogicalDecodingContext::output_writer_private |
Definition at line 83 of file logical.h.
Referenced by LogicalOutputWrite().
LogicalDecodingXLogPageReadCB LogicalDecodingContext::page_read |
Definition at line 44 of file logical.h.
Referenced by DecodingContextFindStartpoint(), pg_logical_replication_slot_advance(), StartupDecodingContext(), and XLogSendLogical().
LogicalOutputPluginWriterPrepareWrite LogicalDecodingContext::prepare_write |
Definition at line 66 of file logical.h.
Referenced by OutputPluginPrepareWrite(), and StartupDecodingContext().
bool LogicalDecodingContext::prepared_write |
Definition at line 99 of file logical.h.
Referenced by OutputPluginPrepareWrite(), and OutputPluginWrite().
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().
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().
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().
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().
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().
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().
LogicalOutputPluginWriterUpdateProgress LogicalDecodingContext::update_progress |
Definition at line 68 of file logical.h.
Referenced by OutputPluginUpdateProgress(), and StartupDecodingContext().
LogicalOutputPluginWriterWrite LogicalDecodingContext::write |
Definition at line 67 of file logical.h.
Referenced by OutputPluginWrite(), and StartupDecodingContext().
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().
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().