Hackfut Security File Manager
Current Path:
/opt/td-agent/embedded/include/postgresql/server/replication
opt
/
td-agent
/
embedded
/
include
/
postgresql
/
server
/
replication
/
📁
..
📄
basebackup.h
(833 B)
📄
decode.h
(569 B)
📄
logical.h
(2.79 KB)
📄
logicalfuncs.h
(967 B)
📄
message.h
(1.32 KB)
📄
origin.h
(3.1 KB)
📄
output_plugin.h
(3.24 KB)
📄
reorderbuffer.h
(11.77 KB)
📄
slot.h
(5.59 KB)
📄
snapbuild.h
(2.74 KB)
📄
syncrep.h
(2.75 KB)
📄
walreceiver.h
(5.76 KB)
📄
walsender.h
(1.7 KB)
📄
walsender_private.h
(2.93 KB)
Editing: output_plugin.h
/*------------------------------------------------------------------------- * output_plugin.h * PostgreSQL Logical Decode Plugin Interface * * Copyright (c) 2012-2016, PostgreSQL Global Development Group * *------------------------------------------------------------------------- */ #ifndef OUTPUT_PLUGIN_H #define OUTPUT_PLUGIN_H #include "replication/reorderbuffer.h" struct LogicalDecodingContext; struct OutputPluginCallbacks; typedef enum OutputPluginOutputType { OUTPUT_PLUGIN_BINARY_OUTPUT, OUTPUT_PLUGIN_TEXTUAL_OUTPUT } OutputPluginOutputType; /* * Options set by the output plugin, in the startup callback. */ typedef struct OutputPluginOptions { OutputPluginOutputType output_type; } OutputPluginOptions; /* * Type of the shared library symbol _PG_output_plugin_init that is looked up * when loading an output plugin shared library. */ typedef void (*LogicalOutputPluginInit) (struct OutputPluginCallbacks *cb); /* * Callback that gets called in a user-defined plugin. ctx->private_data can * be set to some private data. * * "is_init" will be set to "true" if the decoding slot just got defined. When * the same slot is used from there one, it will be "false". */ typedef void (*LogicalDecodeStartupCB) (struct LogicalDecodingContext *ctx, OutputPluginOptions *options, bool is_init); /* * Callback called for every (explicit or implicit) BEGIN of a successful * transaction. */ typedef void (*LogicalDecodeBeginCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn); /* * Callback for every individual change in a successful transaction. */ typedef void (*LogicalDecodeChangeCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, Relation relation, ReorderBufferChange *change); /* * Called for every (explicit or implicit) COMMIT of a successful transaction. */ typedef void (*LogicalDecodeCommitCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr commit_lsn); /* * Called for the generic logical decoding messages. */ typedef void (*LogicalDecodeMessageCB) (struct LogicalDecodingContext *ctx, ReorderBufferTXN *txn, XLogRecPtr message_lsn, bool transactional, const char *prefix, Size message_size, const char *message); /* * Filter changes by origin. */ typedef bool (*LogicalDecodeFilterByOriginCB) (struct LogicalDecodingContext *ctx, RepOriginId origin_id); /* * Called to shutdown an output plugin. */ typedef void (*LogicalDecodeShutdownCB) (struct LogicalDecodingContext *ctx); /* * Output plugin callbacks */ typedef struct OutputPluginCallbacks { LogicalDecodeStartupCB startup_cb; LogicalDecodeBeginCB begin_cb; LogicalDecodeChangeCB change_cb; LogicalDecodeCommitCB commit_cb; LogicalDecodeMessageCB message_cb; LogicalDecodeFilterByOriginCB filter_by_origin_cb; LogicalDecodeShutdownCB shutdown_cb; } OutputPluginCallbacks; /* Functions in replication/logical/logical.c */ extern void OutputPluginPrepareWrite(struct LogicalDecodingContext *ctx, bool last_write); extern void OutputPluginWrite(struct LogicalDecodingContext *ctx, bool last_write); #endif /* OUTPUT_PLUGIN_H */
Upload File
Create Folder