PostgreSQL Source Code  git master
Data Fields
Subscription Struct Reference

#include <pg_subscription.h>

Data Fields

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
 
char * conninfo
 
char * slotname
 
char * synccommit
 
List * publications
 
char * origin
 

Detailed Description

Definition at line 129 of file pg_subscription.h.

Field Documentation

◆ binary

bool Subscription::binary

Definition at line 140 of file pg_subscription.h.

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

◆ conninfo

char* Subscription::conninfo

Definition at line 154 of file pg_subscription.h.

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

◆ dbid

Oid Subscription::dbid

Definition at line 132 of file pg_subscription.h.

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

◆ disableonerr

bool Subscription::disableonerr

Definition at line 145 of file pg_subscription.h.

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

◆ enabled

bool Subscription::enabled

Definition at line 139 of file pg_subscription.h.

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

◆ failover

bool Subscription::failover

Definition at line 150 of file pg_subscription.h.

Referenced by GetSubscription(), and LogicalRepSyncTableStart().

◆ name

char* Subscription::name

Definition at line 136 of file pg_subscription.h.

Referenced by AlterSubscription(), AlterSubscription_refresh(), ApplyLauncherMain(), clear_subscription_skip_lsn(), DisableSubscriptionAndExit(), FreeSubscription(), get_subscription_list(), GetSubscription(), InitializeLogRepWorker(), maybe_reread_subscription(), pa_launch_parallel_worker(), pg_attribute_noreturn(), process_syncing_tables_for_apply(), ProcessParallelApplyInterrupts(), run_apply_worker(), and should_apply_changes_for_rel().

◆ oid

Oid Subscription::oid

Definition at line 131 of file pg_subscription.h.

Referenced by AlterSubscription_refresh(), apply_handle_commit_prepared(), apply_handle_prepare_internal(), apply_handle_rollback_prepared(), ApplyLauncherMain(), clear_subscription_skip_lsn(), DisableSubscriptionAndExit(), FetchTableStates(), get_subscription_list(), GetSubscription(), logicalrep_rel_open(), LogicalRepSyncTableStart(), pa_launch_parallel_worker(), pa_start_subtrans(), pa_stream_abort(), ParallelApplyWorkerMain(), process_syncing_tables_for_apply(), run_apply_worker(), run_tablesync_worker(), start_apply(), and start_table_sync().

◆ origin

char* Subscription::origin

Definition at line 158 of file pg_subscription.h.

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

◆ owner

Oid Subscription::owner

Definition at line 137 of file pg_subscription.h.

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

◆ ownersuperuser

bool Subscription::ownersuperuser

Definition at line 138 of file pg_subscription.h.

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

◆ passwordrequired

bool Subscription::passwordrequired

Definition at line 148 of file pg_subscription.h.

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

◆ publications

List* Subscription::publications

Definition at line 157 of file pg_subscription.h.

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

◆ runasowner

bool Subscription::runasowner

Definition at line 149 of file pg_subscription.h.

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

◆ skiplsn

XLogRecPtr Subscription::skiplsn

Definition at line 134 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 155 of file pg_subscription.h.

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

◆ stream

char Subscription::stream

Definition at line 142 of file pg_subscription.h.

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

◆ synccommit

char* Subscription::synccommit

Definition at line 156 of file pg_subscription.h.

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

◆ twophasestate

char Subscription::twophasestate

Definition at line 144 of file pg_subscription.h.

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

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