12 #ifndef WORKER_INTERNAL_H 13 #define WORKER_INTERNAL_H
int logicalrep_sync_worker_count(Oid subid)
LogicalRepWorker * logicalrep_worker_find(Oid subid, Oid relid, bool only_running)
Subscription * MySubscription
TimestampTz last_send_time
void invalidate_syncing_table_states(Datum arg, int cacheid, uint32 hashvalue)
struct LogicalRepWorker LogicalRepWorker
struct WalReceiverConn * wrconn
#define OidIsValid(objectId)
List * logicalrep_workers_find(Oid subid, bool only_running)
void logicalrep_worker_launch(Oid dbid, Oid subid, const char *subname, Oid userid, Oid relid)
void logicalrep_worker_wakeup(Oid subid, Oid relid)
char * LogicalRepSyncTableStart(XLogRecPtr *origin_startpos)
static bool am_tablesync_worker(void)
void logicalrep_worker_wakeup_ptr(LogicalRepWorker *worker)
MemoryContext ApplyContext
void logicalrep_worker_stop(Oid subid, Oid relid)
void process_syncing_tables(XLogRecPtr current_lsn)
TimestampTz last_recv_time
bool in_remote_transaction
void logicalrep_worker_stop_at_commit(Oid subid, Oid relid)
void logicalrep_worker_attach(int slot)
LogicalRepWorker * MyLogicalRepWorker