mirror of
https://github.com/postgres/postgres.git
synced 2025-07-30 11:03:19 +03:00
aea76d128a
It was introduced alongside replication origins, by commit
5aa2350426, so backpatch to 9.5.
Pointed out by Fujii Masao
89 lines
3.1 KiB
C
89 lines
3.1 KiB
C
/*-------------------------------------------------------------------------
|
|
* origin.h
|
|
* Exports from replication/logical/origin.c
|
|
*
|
|
* Copyright (c) 2013-2015, PostgreSQL Global Development Group
|
|
*
|
|
* src/include/replication/origin.h
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef PG_ORIGIN_H
|
|
#define PG_ORIGIN_H
|
|
|
|
#include "fmgr.h"
|
|
#include "access/xlog.h"
|
|
#include "access/xlogdefs.h"
|
|
#include "access/xlogreader.h"
|
|
#include "catalog/pg_replication_origin.h"
|
|
|
|
typedef struct xl_replorigin_set
|
|
{
|
|
XLogRecPtr remote_lsn;
|
|
RepOriginId node_id;
|
|
bool force;
|
|
} xl_replorigin_set;
|
|
|
|
typedef struct xl_replorigin_drop
|
|
{
|
|
RepOriginId node_id;
|
|
} xl_replorigin_drop;
|
|
|
|
#define XLOG_REPLORIGIN_SET 0x00
|
|
#define XLOG_REPLORIGIN_DROP 0x10
|
|
|
|
#define InvalidRepOriginId 0
|
|
#define DoNotReplicateId PG_UINT16_MAX
|
|
|
|
extern PGDLLIMPORT RepOriginId replorigin_session_origin;
|
|
extern PGDLLIMPORT XLogRecPtr replorigin_session_origin_lsn;
|
|
extern PGDLLIMPORT TimestampTz replorigin_session_origin_timestamp;
|
|
|
|
/* API for querying & manipulating replication origins */
|
|
extern RepOriginId replorigin_by_name(char *name, bool missing_ok);
|
|
extern RepOriginId replorigin_create(char *name);
|
|
extern void replorigin_drop(RepOriginId roident);
|
|
extern bool replorigin_by_oid(RepOriginId roident, bool missing_ok,
|
|
char **roname);
|
|
|
|
/* API for querying & manipulating replication progress tracking */
|
|
extern void replorigin_advance(RepOriginId node,
|
|
XLogRecPtr remote_commit,
|
|
XLogRecPtr local_commit,
|
|
bool go_backward, bool wal_log);
|
|
extern XLogRecPtr replorigin_get_progress(RepOriginId node, bool flush);
|
|
|
|
extern void replorigin_session_advance(XLogRecPtr remote_commit,
|
|
XLogRecPtr local_commit);
|
|
extern void replorigin_session_setup(RepOriginId node);
|
|
extern void replorigin_session_reset(void);
|
|
extern XLogRecPtr replorigin_session_get_progress(bool flush);
|
|
|
|
/* Checkpoint/Startup integration */
|
|
extern void CheckPointReplicationOrigin(void);
|
|
extern void StartupReplicationOrigin(void);
|
|
|
|
/* WAL logging */
|
|
void replorigin_redo(XLogReaderState *record);
|
|
void replorigin_desc(StringInfo buf, XLogReaderState *record);
|
|
const char *replorigin_identify(uint8 info);
|
|
|
|
/* shared memory allocation */
|
|
extern Size ReplicationOriginShmemSize(void);
|
|
extern void ReplicationOriginShmemInit(void);
|
|
|
|
/* SQL callable functions */
|
|
extern Datum pg_replication_origin_create(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_drop(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_oid(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_session_setup(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_session_reset(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_session_is_setup(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_session_progress(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_xact_setup(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_xact_reset(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_advance(PG_FUNCTION_ARGS);
|
|
extern Datum pg_replication_origin_progress(PG_FUNCTION_ARGS);
|
|
extern Datum pg_show_replication_origin_status(PG_FUNCTION_ARGS);
|
|
|
|
#endif /* PG_ORIGIN_H */
|