18#ifndef PG_SUBSCRIPTION_REL_H
19#define PG_SUBSCRIPTION_REL_H
23#include "catalog/pg_subscription_rel_d.h"
31CATALOG(pg_subscription_rel,6102,SubscriptionRelRelationId)
52DECLARE_UNIQUE_INDEX_PKEY(pg_subscription_rel_srrelid_srsubid_index, 6117, SubscriptionRelSrrelidSrsubidIndexId, pg_subscription_rel, btree(srrelid oid_ops, srsubid oid_ops));
54MAKE_SYSCACHE(SUBSCRIPTIONRELMAP, pg_subscription_rel_srrelid_srsubid_index, 64);
56#ifdef EXPOSE_TO_CLIENT_CODE
62#define SUBREL_STATE_INIT 'i'
63#define SUBREL_STATE_DATASYNC 'd'
65#define SUBREL_STATE_FINISHEDCOPY 'f'
67#define SUBREL_STATE_SYNCDONE 's'
69#define SUBREL_STATE_READY 'r'
72#define SUBREL_STATE_UNKNOWN '\0'
73#define SUBREL_STATE_SYNCWAIT 'w'
74#define SUBREL_STATE_CATCHUP 'c'
#define BKI_LOOKUP(catalog)
FormData_pg_subscription_rel * Form_pg_subscription_rel
List * GetSubscriptionRelations(Oid subid, bool not_ready)
FormData_pg_subscription_rel
struct SubscriptionRelState SubscriptionRelState
void RemoveSubscriptionRel(Oid subid, Oid relid)
char GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn)
void AddSubscriptionRelState(Oid subid, Oid relid, char state, XLogRecPtr sublsn, bool retain_lock)
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)
MAKE_SYSCACHE(SUBSCRIPTIONRELMAP, pg_subscription_rel_srrelid_srsubid_index, 64)
CATALOG(pg_subscription_rel, 6102, SubscriptionRelRelationId)