18 #ifndef PG_SUBSCRIPTION_REL_H
19 #define PG_SUBSCRIPTION_REL_H
23 #include "catalog/pg_subscription_rel_d.h"
31 CATALOG(pg_subscription_rel,6102,SubscriptionRelRelationId)
52 DECLARE_UNIQUE_INDEX_PKEY(pg_subscription_rel_srrelid_srsubid_index, 6117, SubscriptionRelSrrelidSrsubidIndexId, pg_subscription_rel, btree(srrelid oid_ops, srsubid oid_ops));
54 #ifdef EXPOSE_TO_CLIENT_CODE
60 #define SUBREL_STATE_INIT 'i'
61 #define SUBREL_STATE_DATASYNC 'd'
63 #define SUBREL_STATE_FINISHEDCOPY 'f'
65 #define SUBREL_STATE_SYNCDONE 's'
67 #define SUBREL_STATE_READY 'r'
70 #define SUBREL_STATE_UNKNOWN '\0'
71 #define SUBREL_STATE_SYNCWAIT 'w'
72 #define SUBREL_STATE_CATCHUP 'c'
#define BKI_LOOKUP(catalog)
FormData_pg_subscription_rel * Form_pg_subscription_rel
FormData_pg_subscription_rel
struct SubscriptionRelState SubscriptionRelState
void RemoveSubscriptionRel(Oid subid, Oid relid)
List * GetSubscriptionRelations(Oid subid, bool not_ready)
char GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn)
void UpdateSubscriptionRelState(Oid subid, Oid relid, char state, XLogRecPtr sublsn)
DECLARE_UNIQUE_INDEX_PKEY(pg_subscription_rel_srrelid_srsubid_index, 6117, SubscriptionRelSrrelidSrsubidIndexId, pg_subscription_rel, btree(srrelid oid_ops, srsubid oid_ops))
bool HasSubscriptionRelations(Oid subid)
CATALOG(pg_subscription_rel, 6102, SubscriptionRelRelationId)
void AddSubscriptionRelState(Oid subid, Oid relid, char state, XLogRecPtr sublsn)