PostgreSQL Source Code
git master
|
#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 |
Definition at line 129 of file pg_subscription.h.
bool Subscription::binary |
Definition at line 140 of file pg_subscription.h.
Referenced by copy_table(), GetSubscription(), maybe_reread_subscription(), and set_stream_options().
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().
Oid Subscription::dbid |
Definition at line 132 of file pg_subscription.h.
Referenced by ApplyLauncherMain(), get_subscription_list(), GetSubscription(), and maybe_reread_subscription().
bool Subscription::disableonerr |
Definition at line 145 of file pg_subscription.h.
Referenced by GetSubscription(), start_apply(), and start_table_sync().
bool Subscription::enabled |
Definition at line 139 of file pg_subscription.h.
Referenced by AlterSubscription(), ApplyLauncherMain(), CheckAlterSubOption(), get_subscription_list(), GetSubscription(), and InitializeLogRepWorker().
bool Subscription::failover |
Definition at line 150 of file pg_subscription.h.
Referenced by GetSubscription(), and LogicalRepSyncTableStart().
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(), LogicalRepSyncTableStart(), 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 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(), ReportApplyConflict(), run_apply_worker(), run_tablesync_worker(), start_apply(), and start_table_sync().
char* Subscription::origin |
Definition at line 158 of file pg_subscription.h.
Referenced by AlterSubscription_refresh(), GetSubscription(), maybe_reread_subscription(), and set_stream_options().
Oid Subscription::owner |
Definition at line 137 of file pg_subscription.h.
Referenced by ApplyLauncherMain(), get_subscription_list(), GetSubscription(), and maybe_reread_subscription().
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().
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().
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().
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().
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().
char* Subscription::slotname |
Definition at line 155 of file pg_subscription.h.
Referenced by AlterSubscription(), CheckAlterSubOption(), FreeSubscription(), GetSubscription(), maybe_reread_subscription(), and run_apply_worker().
char Subscription::stream |
Definition at line 142 of file pg_subscription.h.
Referenced by GetSubscription(), maybe_reread_subscription(), and set_stream_options().
char* Subscription::synccommit |
Definition at line 156 of file pg_subscription.h.
Referenced by GetSubscription(), InitializeLogRepWorker(), and maybe_reread_subscription().
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().