diff options
Diffstat (limited to 'src/include')
| -rw-r--r-- | src/include/miscadmin.h | 1 | ||||
| -rw-r--r-- | src/include/replication/slotsync.h | 21 |
2 files changed, 21 insertions, 1 deletions
diff --git a/src/include/miscadmin.h b/src/include/miscadmin.h index 0445fbf61d7..612fb5f42e0 100644 --- a/src/include/miscadmin.h +++ b/src/include/miscadmin.h @@ -333,6 +333,7 @@ typedef enum BackendType B_BG_WRITER, B_CHECKPOINTER, B_LOGGER, + B_SLOTSYNC_WORKER, B_STANDALONE_BACKEND, B_STARTUP, B_WAL_RECEIVER, diff --git a/src/include/replication/slotsync.h b/src/include/replication/slotsync.h index e86d8a47b85..726d65f9b62 100644 --- a/src/include/replication/slotsync.h +++ b/src/include/replication/slotsync.h @@ -14,8 +14,27 @@ #include "replication/walreceiver.h" -extern void ValidateSlotSyncParams(void); +extern PGDLLIMPORT bool sync_replication_slots; + +/* + * GUCs needed by slot sync worker to connect to the primary + * server and carry on with slots synchronization. + */ +extern PGDLLIMPORT char *PrimaryConnInfo; +extern PGDLLIMPORT char *PrimarySlotName; + +extern char *CheckAndGetDbnameFromConninfo(void); +extern bool ValidateSlotSyncParams(int elevel); + +#ifdef EXEC_BACKEND +extern void ReplSlotSyncWorkerMain(int argc, char *argv[]) pg_attribute_noreturn(); +#endif +extern int StartSlotSyncWorker(void); + +extern void ShutDownSlotSync(void); +extern bool SlotSyncWorkerCanRestart(void); extern bool IsSyncingReplicationSlots(void); +extern bool IsLogicalSlotSyncWorker(void); extern Size SlotSyncShmemSize(void); extern void SlotSyncShmemInit(void); extern void SyncReplicationSlots(WalReceiverConn *wrconn); |