PostgreSQL Source Code
git master
|
Go to the source code of this file.
Data Structures | |
struct | Subscription |
Macros | |
#define | PgSubscriptionToastTable 4183 |
#define | PgSubscriptionToastIndex 4184 |
#define | SubscriptionObjectIndexId 6114 |
#define | SubscriptionNameIndexId 6115 |
Typedefs | |
typedef FormData_pg_subscription * | Form_pg_subscription |
typedef struct Subscription | Subscription |
Functions | |
CATALOG (pg_subscription, 6100, SubscriptionRelationId) BKI_SHARED_RELATION BKI_ROWTYPE_OID(6101 | |
Oid subdbid | BKI_LOOKUP (pg_database) |
Oid subowner | BKI_LOOKUP (pg_authid) |
DECLARE_TOAST (pg_subscription, 4183, 4184) | |
DECLARE_UNIQUE_INDEX_PKEY (pg_subscription_oid_index, 6114, on pg_subscription using btree(oid oid_ops)) | |
DECLARE_UNIQUE_INDEX (pg_subscription_subname_index, 6115, on pg_subscription using btree(subdbid oid_ops, subname name_ops)) | |
Subscription * | GetSubscription (Oid subid, bool missing_ok) |
void | FreeSubscription (Subscription *sub) |
Oid | get_subscription_oid (const char *subname, bool missing_ok) |
char * | get_subscription_name (Oid subid, bool missing_ok) |
int | CountDBSubscriptions (Oid dbid) |
Variables | |
SubscriptionRelation_Rowtype_Id | BKI_SCHEMA_MACRO |
NameData | subname |
bool | subenabled |
bool | subbinary |
bool | substream |
FormData_pg_subscription | |
#define PgSubscriptionToastIndex 4184 |
Definition at line 76 of file pg_subscription.h.
Referenced by IsSharedRelation().
#define PgSubscriptionToastTable 4183 |
Definition at line 75 of file pg_subscription.h.
Referenced by IsSharedRelation().
#define SubscriptionNameIndexId 6115 |
Definition at line 81 of file pg_subscription.h.
Referenced by IsSharedRelation().
#define SubscriptionObjectIndexId 6114 |
Definition at line 79 of file pg_subscription.h.
Referenced by CreateSubscription(), and IsSharedRelation().
Definition at line 72 of file pg_subscription.h.
typedef struct Subscription Subscription |
Oid subdbid BKI_LOOKUP | ( | pg_database | ) |
Oid subowner BKI_LOOKUP | ( | pg_authid | ) |
CATALOG | ( | pg_subscription | , |
6100 | , | ||
SubscriptionRelationId | |||
) |
int CountDBSubscriptions | ( | Oid | dbid | ) |
Definition at line 116 of file pg_subscription.c.
References BTEqualStrategyNumber, HeapTupleIsValid, InvalidOid, NoLock, ObjectIdGetDatum, RowExclusiveLock, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by dropdb().
DECLARE_TOAST | ( | pg_subscription | , |
4183 | , | ||
4184 | |||
) |
DECLARE_UNIQUE_INDEX | ( | pg_subscription_subname_index | , |
6115 | , | ||
on pg_subscription using | btreesubdbid oid_ops, subname name_ops | ||
) |
DECLARE_UNIQUE_INDEX_PKEY | ( | pg_subscription_oid_index | , |
6114 | , | ||
on pg_subscription using | btreeoid oid_ops | ||
) |
void FreeSubscription | ( | Subscription * | sub | ) |
Definition at line 148 of file pg_subscription.c.
References Subscription::conninfo, list_free_deep(), Subscription::name, pfree(), Subscription::publications, and Subscription::slotname.
Referenced by maybe_reread_subscription().
Definition at line 185 of file pg_subscription.c.
References elog, ERROR, GETSTRUCT, HeapTupleIsValid, NameStr, ObjectIdGetDatum, pstrdup(), ReleaseSysCache(), SearchSysCache1(), subname, and SUBSCRIPTIONOID.
Referenced by getObjectDescription(), getObjectIdentityParts(), and RemoveSubscriptionRel().
Definition at line 165 of file pg_subscription.c.
References CStringGetDatum, ereport, errcode(), errmsg(), ERROR, GetSysCacheOid2, MyDatabaseId, OidIsValid, and SUBSCRIPTIONNAME.
Referenced by get_object_address_unqualified().
Subscription* GetSubscription | ( | Oid | subid, |
bool | missing_ok | ||
) |
Definition at line 43 of file pg_subscription.c.
References Assert, Subscription::binary, Subscription::conninfo, DatumGetArrayTypeP, DatumGetName, Subscription::dbid, elog, Subscription::enabled, ERROR, GETSTRUCT, HeapTupleIsValid, Subscription::name, NameStr, ObjectIdGetDatum, Subscription::oid, Subscription::owner, palloc(), pstrdup(), Subscription::publications, ReleaseSysCache(), SearchSysCache1(), Subscription::slotname, Subscription::stream, SUBSCRIPTIONOID, Subscription::synccommit, SysCacheGetAttr(), textarray_to_stringlist(), and TextDatumGetCString.
Referenced by AlterSubscription(), ApplyWorkerMain(), and maybe_reread_subscription().
SubscriptionRelation_Rowtype_Id BKI_SCHEMA_MACRO |
Definition at line 40 of file pg_subscription.h.
FormData_pg_subscription |
Definition at line 70 of file pg_subscription.h.
bool subbinary |
Definition at line 52 of file pg_subscription.h.
bool subenabled |
Definition at line 49 of file pg_subscription.h.
NameData subname |
Definition at line 45 of file pg_subscription.h.
Referenced by _copyAlterSubscriptionStmt(), _copyCreateSubscriptionStmt(), _copyDropSubscriptionStmt(), _copyRenameStmt(), _equalAlterSubscriptionStmt(), _equalCreateSubscriptionStmt(), _equalDropSubscriptionStmt(), _equalRenameStmt(), DropSubscription(), get_subscription_name(), getObjectDescription(), getObjectIdentityParts(), and plperl_create_sub().
bool substream |
Definition at line 55 of file pg_subscription.h.