Beta Shell v2.0

File Manager

~ /usr/pgsql-11/include/server/replication

Name	Size	Perms	Modified	Actions
[ .. / .. ]
basebackup.h	837 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
decode.h	569 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logical.h	3.48 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logicalfuncs.h	587 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logicallauncher.h	975 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logicalproto.h	3.76 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logicalrelation.h	1.27 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
logicalworker.h	515 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
message.h	1.32 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
origin.h	2.33 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
output_plugin.h	3.61 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
pgoutput.h	653 B	-rw-r--r--	2023-11-20 11:17:48	Edit Del
reorderbuffer.h	12.93 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
slot.h	6.65 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
snapbuild.h	3.01 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
syncrep.h	3.56 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
walreceiver.h	10.4 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
walsender.h	1.82 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
walsender_private.h	3.41 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del
worker_internal.h	2.64 KB	-rw-r--r--	2023-11-20 11:17:48	Edit Del

Editing: origin.h (2.33 KB)

/*-------------------------------------------------------------------------
 * origin.h
 *	   Exports from replication/logical/origin.c
 *
 * Copyright (c) 2013-2018, 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, bool nowait);
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);

#endif							/* PG_ORIGIN_H */