Subscription Struct Reference

#include <pg_subscription.h>

Data Fields
MemoryContext	cxt
Oid	oid
Oid	dbid
XLogRecPtr	skiplsn
char *	name
Oid	owner
bool	ownersuperuser
bool	enabled
bool	binary
char	stream
char	twophasestate
bool	disableonerr
bool	passwordrequired
bool	runasowner
bool	failover
bool	retaindeadtuples
int32	maxretention
bool	retentionactive
Oid	conflictlogrelid
char *	conninfo
char *	slotname
char *	synccommit
char *	walrcvtimeout
List *	publications
char *	origin
char *	conflictlogdest

Detailed Description

Definition at line 139 of file pg_subscription.h.

Field Documentation

binary

bool Subscription::binary

Definition at line 152 of file pg_subscription.h.

Referenced by copy_table(), GetSubscription(), maybe_reread_subscription(), and set_stream_options().

conflictlogdest

char* Subscription::conflictlogdest

Definition at line 183 of file pg_subscription.h.

Referenced by AlterSubscription(), and GetSubscription().

conflictlogrelid

Oid Subscription::conflictlogrelid

Definition at line 175 of file pg_subscription.h.

Referenced by alter_sub_conflict_log_dest(), and GetSubscription().

conninfo

char* Subscription::conninfo

Definition at line 176 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), GetSubscription(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), maybe_reread_subscription(), run_apply_worker(), and SetupApplyOrSyncWorker().

cxt

MemoryContext Subscription::cxt

Definition at line 141 of file pg_subscription.h.

Referenced by GetSubscription(), InitializeLogRepWorker(), and maybe_reread_subscription().

dbid

Oid Subscription::dbid

Definition at line 144 of file pg_subscription.h.

Referenced by ApplyLauncherMain(), get_subscription_list(), GetSubscription(), and maybe_reread_subscription().

disableonerr

bool Subscription::disableonerr

Definition at line 157 of file pg_subscription.h.

Referenced by GetSubscription(), start_apply(), start_sequence_sync(), and start_table_sync().

enabled

bool Subscription::enabled

Definition at line 151 of file pg_subscription.h.

Referenced by AlterSubscription(), ApplyLauncherMain(), CheckAlterSubOption(), get_subscription_list(), GetSubscription(), and InitializeLogRepWorker().

failover

bool Subscription::failover

Definition at line 162 of file pg_subscription.h.

Referenced by GetSubscription(), and LogicalRepSyncTableStart().

maxretention

int32 Subscription::maxretention

Definition at line 168 of file pg_subscription.h.

Referenced by adjust_xid_advance_interval(), AlterSubscription(), GetSubscription(), LogicalRepApplyLoop(), resume_conflict_info_retention(), and should_stop_conflict_info_retention().

name

char* Subscription::name

Definition at line 148 of file pg_subscription.h.

Referenced by alter_sub_conflict_log_dest(), AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), ApplyLauncherMain(), clear_subscription_skip_lsn(), copy_sequences(), DisableSubscriptionAndExit(), FinishSyncWorker(), get_subscription_list(), GetSubscription(), InitializeLogRepWorker(), launch_sync_worker(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), maybe_reread_subscription(), pa_launch_parallel_worker(), ProcessParallelApplyInterrupts(), ProcessSyncingTablesForApply(), report_sequence_errors(), resume_conflict_info_retention(), run_apply_worker(), set_wal_receiver_timeout(), should_apply_changes_for_rel(), and stop_conflict_info_retention().

oid

Oid Subscription::oid

Definition at line 143 of file pg_subscription.h.

Referenced by alter_sub_conflict_log_dest(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), apply_handle_commit_prepared(), apply_handle_prepare_internal(), apply_handle_rollback_prepared(), ApplyLauncherMain(), clear_subscription_skip_lsn(), copy_sequence(), DisableSubscriptionAndExit(), FetchRelationStates(), get_subscription_list(), GetSubscription(), launch_sync_worker(), logicalrep_rel_open(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), pa_launch_parallel_worker(), pa_start_subtrans(), pa_stream_abort(), ParallelApplyWorkerMain(), ProcessSyncingTablesForApply(), ReportApplyConflict(), run_apply_worker(), run_tablesync_worker(), start_apply(), start_sequence_sync(), start_table_sync(), and update_retention_status().

origin

char* Subscription::origin

Definition at line 181 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), GetSubscription(), maybe_reread_subscription(), and set_stream_options().

owner

Oid Subscription::owner

Definition at line 149 of file pg_subscription.h.

Referenced by alter_sub_conflict_log_dest(), ApplyLauncherMain(), get_subscription_list(), GetSubscription(), and maybe_reread_subscription().

ownersuperuser

bool Subscription::ownersuperuser

Definition at line 150 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), GetSubscription(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), maybe_reread_subscription(), and run_apply_worker().

passwordrequired

bool Subscription::passwordrequired

Definition at line 160 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), GetSubscription(), LogicalRepSyncSequences(), LogicalRepSyncTableStart(), maybe_reread_subscription(), and run_apply_worker().

publications

List* Subscription::publications

Definition at line 180 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), AlterSubscription_refresh_seq(), fetch_remote_table_info(), GetSubscription(), maybe_reread_subscription(), and set_stream_options().

retaindeadtuples

bool Subscription::retaindeadtuples

Definition at line 166 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), ApplyLauncherMain(), can_advance_nonremovable_xid(), DisableSubscriptionAndExit(), FindDeletedTupleInLocalRel(), get_subscription_list(), GetSubscription(), and InitializeLogRepWorker().

retentionactive

bool Subscription::retentionactive

Definition at line 171 of file pg_subscription.h.

Referenced by adjust_xid_advance_interval(), AlterSubscription(), ApplyLauncherMain(), DisableSubscriptionAndExit(), get_subscription_list(), GetSubscription(), InitializeLogRepWorker(), LogicalRepApplyLoop(), stop_conflict_info_retention(), update_retention_status(), and wait_for_local_flush().

runasowner

bool Subscription::runasowner

Definition at line 161 of file pg_subscription.h.

Referenced by apply_handle_delete(), apply_handle_insert(), apply_handle_truncate(), apply_handle_update(), copy_sequence(), GetSubscription(), LogicalRepSyncTableStart(), and report_sequence_errors().

skiplsn

XLogRecPtr Subscription::skiplsn

Definition at line 146 of file pg_subscription.h.

Referenced by clear_subscription_skip_lsn(), GetSubscription(), maybe_start_skipping_changes(), and pa_can_start().

slotname

char* Subscription::slotname

Definition at line 177 of file pg_subscription.h.

Referenced by AlterSubscription(), CheckAlterSubOption(), GetSubscription(), maybe_reread_subscription(), and run_apply_worker().

stream

char Subscription::stream

Definition at line 154 of file pg_subscription.h.

Referenced by GetSubscription(), maybe_reread_subscription(), and set_stream_options().

synccommit

char* Subscription::synccommit

Definition at line 178 of file pg_subscription.h.

Referenced by GetSubscription(), InitializeLogRepWorker(), and maybe_reread_subscription().

twophasestate

char Subscription::twophasestate

Definition at line 156 of file pg_subscription.h.

Referenced by AlterSubscription(), GetSubscription(), maybe_reread_subscription(), ProcessSyncingTablesForApply(), and run_apply_worker().

walrcvtimeout

char* Subscription::walrcvtimeout

Definition at line 179 of file pg_subscription.h.

Referenced by GetSubscription(), and set_wal_receiver_timeout().

---

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

• src/include/catalog/pg_subscription.h