1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
/*-------------------------------------------------------------------------
*
* pglogical_node.h
* pglogical node and connection catalog manipulation functions
*
* Copyright (c) 2015, PostgreSQL Global Development Group
*
* IDENTIFICATION
* pglogical_node.h
*
*-------------------------------------------------------------------------
*/
#ifndef PGLOGICAL_NODE_H
#define PGLOGICAL_NODE_H
#include "datatype/timestamp.h"
typedef struct PGLogicalNode
{
Oid id;
char *name;
} PGLogicalNode;
typedef struct PGlogicalInterface
{
Oid id;
const char *name;
Oid nodeid;
const char *dsn;
} PGlogicalInterface;
typedef struct PGLogicalLocalNode
{
PGLogicalNode *node;
PGlogicalInterface *node_if;
} PGLogicalLocalNode;
typedef struct PGLogicalSubscription
{
Oid id;
char *name;
PGLogicalNode *origin;
PGLogicalNode *target;
PGlogicalInterface *origin_if;
PGlogicalInterface *target_if;
bool enabled;
Interval *apply_delay;
char *slot_name;
List *replication_sets;
List *forward_origins;
bool force_text_transfer;
} PGLogicalSubscription;
extern void create_node(PGLogicalNode *node);
extern void drop_node(Oid nodeid);
extern PGLogicalNode *get_node(Oid nodeid);
extern PGLogicalNode *get_node_by_name(const char *name, bool missing_ok);
extern void create_node_interface(PGlogicalInterface *node);
extern void drop_node_interface(Oid ifid);
extern void drop_node_interfaces(Oid nodeid);
extern PGlogicalInterface *get_node_interface(Oid ifid);
extern PGlogicalInterface *get_node_interface_by_name(Oid nodeid,
const char *name,
bool missing_ok);
extern void create_local_node(Oid nodeid, Oid ifid);
extern void drop_local_node(void);
extern PGLogicalLocalNode *get_local_node(bool for_update, bool missing_ok);
extern void create_subscription(PGLogicalSubscription *sub);
extern void alter_subscription(PGLogicalSubscription *sub);
extern void drop_subscription(Oid subid);
extern PGLogicalSubscription *get_subscription(Oid subid);
extern PGLogicalSubscription *get_subscription_by_name(const char *name,
bool missing_ok);
extern List *get_node_subscriptions(Oid nodeid, bool origin);
#endif /* PGLOGICAL_NODE_H */
|
