src/include/replication/logicalworker.h

   1 /*-------------------------------------------------------------------------
   2  *
   3  * logicalworker.h
   4  *        Exports for logical replication workers.
   5  *
   6  * Portions Copyright (c) 2016-2025, PostgreSQL Global Development Group
   7  *
   8  * src/include/replication/logicalworker.h
   9  *
  10  *-------------------------------------------------------------------------
  11  */
  12 #ifndef LOGICALWORKER_H
  13 #define LOGICALWORKER_H
  14
  15 #include <signal.h>
  16
  17 extern PGDLLIMPORT volatile sig_atomic_t ParallelApplyMessagePending;
  18
  19 extern void ApplyWorkerMain(Datum main_arg);
  20 extern void ParallelApplyWorkerMain(Datum main_arg);
  21 extern void TablesyncWorkerMain(Datum main_arg);
  22
  23 extern bool IsLogicalWorker(void);
  24 extern bool IsLogicalParallelApplyWorker(void);
  25
  26 extern void HandleParallelApplyMessageInterrupt(void);
  27 extern void HandleParallelApplyMessages(void);
  28
  29 extern void LogicalRepWorkersWakeupAtCommit(Oid subid);
  30
  31 extern void AtEOXact_LogicalRepWorkers(bool isCommit);
  32
  33 #endif                                                  /* LOGICALWORKER_H */