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
|
#ifndef PGLOGICAL_COMPAT_REPLICATION_ORIGIN_H
#define PGLOGICAL_COMPAT_REPLICATION_ORIGIN_H
#ifndef InvalidRepOriginId
typedef uint16 RepOriginId;
#define InvalidRepOriginId 0
#define DoNotReplicateId PG_UINT16_MAX
#endif
extern PGDLLIMPORT RepOriginId replorigin_session_origin;
extern PGDLLIMPORT XLogRecPtr replorigin_session_origin_lsn;
extern PGDLLIMPORT TimestampTz replorigin_session_origin_timestamp;
extern RepOriginId replorigin_create(char *name);
extern void pgl_replorigin_drop(RepOriginId roident);
extern void replorigin_drop_by_name(char *name, bool missing_ok, bool nowait);
extern RepOriginId replorigin_by_name(char *name, bool missing_ok);
extern void replorigin_session_setup(RepOriginId node);
extern void replorigin_session_reset(void);
extern XLogRecPtr replorigin_session_get_progress(bool flush);
extern void replorigin_advance(RepOriginId node,
XLogRecPtr remote_commit,
XLogRecPtr local_commit,
bool go_backward, bool wal_log);
#endif
|
