#define PG_SUBSCRIPTION_H
#include "catalog/genbki.h"
+#include "nodes/pg_list.h"
/* ----------------
* pg_subscription definition. cpp turns this into
#ifndef PUBLICATIONCMDS_H
#define PUBLICATIONCMDS_H
+#include "catalog/objectaddress.h"
#include "nodes/parsenodes.h"
extern ObjectAddress CreatePublication(CreatePublicationStmt *stmt);
#ifndef SUBSCRIPTIONCMDS_H
#define SUBSCRIPTIONCMDS_H
+#include "catalog/objectaddress.h"
#include "nodes/parsenodes.h"
extern ObjectAddress CreateSubscription(CreateSubscriptionStmt *stmt);
#ifndef PGOUTPUT_H
#define PGOUTPUT_H
+#include "nodes/pg_list.h"
typedef struct PGOutputData
{
#ifndef WORKER_INTERNAL_H
#define WORKER_INTERNAL_H
+#include "access/xlogdefs.h"
#include "catalog/pg_subscription.h"
+#include "datatype/timestamp.h"
#include "storage/lock.h"
typedef struct LogicalRepWorker