src/include/replication/decode.h

   1 /*-------------------------------------------------------------------------
   2  * decode.h
   3  *         PostgreSQL WAL to logical transformation
   4  *
   5  * Portions Copyright (c) 2012-2022, PostgreSQL Global Development Group
   6  *
   7  *-------------------------------------------------------------------------
   8  */
   9 #ifndef DECODE_H
  10 #define DECODE_H
  11
  12 #include "access/xlogreader.h"
  13 #include "access/xlogrecord.h"
  14 #include "replication/logical.h"
  15 #include "replication/reorderbuffer.h"
  16
  17 typedef struct XLogRecordBuffer
  18 {
  19         XLogRecPtr      origptr;
  20         XLogRecPtr      endptr;
  21         XLogReaderState *record;
  22 } XLogRecordBuffer;
  23
  24 extern void xlog_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  25 extern void heap_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  26 extern void heap2_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  27 extern void xact_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  28 extern void standby_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  29 extern void logicalmsg_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf);
  30
  31 extern void LogicalDecodingProcessRecord(LogicalDecodingContext *ctx,
  32                                                                                  XLogReaderState *record);
  33
  34 #endif