PostgreSQL Source Code: src/include/replication/message.h Source File

PostgreSQL Source Code git master
message.h
Go to the documentation of this file.
1/*-------------------------------------------------------------------------
2 * message.h
3 * Exports from replication/logical/message.c
4 *
5 * Copyright (c) 2013-2025, PostgreSQL Global Development Group
6 *
7 * src/include/replication/message.h
8 *-------------------------------------------------------------------------
9 */
10#ifndef PG_LOGICAL_MESSAGE_H
11#define PG_LOGICAL_MESSAGE_H
12
13#include "access/xlog.h"
14#include "access/xlogdefs.h"
15#include "access/xlogreader.h"
16
17/*
18 * Generic logical decoding message wal record.
19 */
20 typedef struct xl_logical_message
21{
22 Oid dbId; /* database Oid emitted from */
23 bool transactional; /* is message transactional? */
24 Size prefix_size; /* length of prefix */
25 Size message_size; /* size of the message */
26 /* payload, including null-terminated prefix of length prefix_size */
27 char message[FLEXIBLE_ARRAY_MEMBER];
28 } xl_logical_message;
29
30 #define SizeOfLogicalMessage (offsetof(xl_logical_message, message))
31
32extern XLogRecPtr LogLogicalMessage(const char *prefix, const char *message,
33 size_t size, bool transactional,
34 bool flush);
35
36/* RMGR API */
37 #define XLOG_LOGICAL_MESSAGE 0x00
38extern void logicalmsg_redo(XLogReaderState *record);
39extern void logicalmsg_desc(StringInfo buf, XLogReaderState *record);
40extern const char *logicalmsg_identify(uint8 info);
41
42#endif /* PG_LOGICAL_MESSAGE_H */
uint8_t uint8
Definition: c.h:536
#define FLEXIBLE_ARRAY_MEMBER
Definition: c.h:470
size_t Size
Definition: c.h:610
XLogRecPtr LogLogicalMessage(const char *prefix, const char *message, size_t size, bool transactional, bool flush)
Definition: message.c:43
struct xl_logical_message xl_logical_message
const char * logicalmsg_identify(uint8 info)
Definition: logicalmsgdesc.c:46
void logicalmsg_desc(StringInfo buf, XLogReaderState *record)
Definition: logicalmsgdesc.c:19
void logicalmsg_redo(XLogReaderState *record)
Definition: message.c:87
static char * buf
Definition: pg_test_fsync.c:72
unsigned int Oid
Definition: postgres_ext.h:32
Definition: message.h:21
Size prefix_size
Definition: message.h:24
bool transactional
Definition: message.h:23
Oid dbId
Definition: message.h:22
char message[FLEXIBLE_ARRAY_MEMBER]
Definition: message.h:27
Size message_size
Definition: message.h:25
uint64 XLogRecPtr
Definition: xlogdefs.h:21

AltStyle によって変換されたページ (->オリジナル) /