| 1 | /*------------------------------------------------------------------------- |
|---|---|
| 2 | * |
| 3 | * logicalrelation.h |
| 4 | * Relation definitions for logical replication relation mapping. |
| 5 | * |
| 6 | * Portions Copyright (c) 2016-2019, PostgreSQL Global Development Group |
| 7 | * |
| 8 | * src/include/replication/logicalrelation.h |
| 9 | * |
| 10 | *------------------------------------------------------------------------- |
| 11 | */ |
| 12 | #ifndef LOGICALRELATION_H |
| 13 | #define LOGICALRELATION_H |
| 14 | |
| 15 | #include "replication/logicalproto.h" |
| 16 | |
| 17 | typedef struct LogicalRepRelMapEntry |
| 18 | { |
| 19 | LogicalRepRelation remoterel; /* key is remoterel.remoteid */ |
| 20 | |
| 21 | /* Mapping to local relation, filled as needed. */ |
| 22 | Oid localreloid; /* local relation id */ |
| 23 | Relation localrel; /* relcache entry */ |
| 24 | AttrNumber *attrmap; /* map of local attributes to remote ones */ |
| 25 | bool updatable; /* Can apply updates/deletes? */ |
| 26 | |
| 27 | /* Sync state. */ |
| 28 | char state; |
| 29 | XLogRecPtr statelsn; |
| 30 | } LogicalRepRelMapEntry; |
| 31 | |
| 32 | extern void logicalrep_relmap_update(LogicalRepRelation *remoterel); |
| 33 | |
| 34 | extern LogicalRepRelMapEntry *logicalrep_rel_open(LogicalRepRelId remoteid, |
| 35 | LOCKMODE lockmode); |
| 36 | extern void logicalrep_rel_close(LogicalRepRelMapEntry *rel, |
| 37 | LOCKMODE lockmode); |
| 38 | |
| 39 | extern void logicalrep_typmap_update(LogicalRepTyp *remotetyp); |
| 40 | extern char *logicalrep_typmap_gettypname(Oid remoteid); |
| 41 | |
| 42 | #endif /* LOGICALRELATION_H */ |
| 43 |