|
- /*-------------------------------------------------------------------------
- * message.h
- * Exports from replication/logical/message.c
- *
- * Copyright (c) 2013-2019, PostgreSQL Global Development Group
- *
- * src/include/replication/message.h
- *-------------------------------------------------------------------------
- */
- #ifndef PG_LOGICAL_MESSAGE_H
- #define PG_LOGICAL_MESSAGE_H
-
- #include "access/xlog.h"
- #include "access/xlogdefs.h"
- #include "access/xlogreader.h"
-
- /*
- * Generic logical decoding message wal record.
- */
- typedef struct xl_logical_message
- {
- Oid dbId; /* database Oid emitted from */
- bool transactional; /* is message transactional? */
- Size prefix_size; /* length of prefix */
- Size message_size; /* size of the message */
- char message[FLEXIBLE_ARRAY_MEMBER]; /* message including the null
- * terminated prefix of length
- * prefix_size */
- } xl_logical_message;
-
- #define SizeOfLogicalMessage (offsetof(xl_logical_message, message))
-
- extern XLogRecPtr LogLogicalMessage(const char *prefix, const char *message,
- size_t size, bool transactional);
-
- /* RMGR API*/
- #define XLOG_LOGICAL_MESSAGE 0x00
- void logicalmsg_redo(XLogReaderState *record);
- void logicalmsg_desc(StringInfo buf, XLogReaderState *record);
- const char *logicalmsg_identify(uint8 info);
-
- #endif /* PG_LOGICAL_MESSAGE_H */
|
