每当创建复制槽或要求其流式传输更改时，都会调用可选的 startup_cb 回调，而不管准备好输出的更改数量如何。

typedef void (*LogicalDecodeStartupCB) (struct LogicalDecodingContext *ctx,
                                        OutputPluginOptions *options,
                                        bool is_init);

当创建复制槽时，is_init 参数将为 true，否则为 false。 options 指向输出插件可以设置的选项结构

typedef struct OutputPluginOptions
{
    OutputPluginOutputType output_type;
    bool        receive_rewrites;
} OutputPluginOptions;

output_type 必须设置为 OUTPUT_PLUGIN_TEXTUAL_OUTPUT 或 OUTPUT_PLUGIN_BINARY_OUTPUT。另请参见 第 49.6.3 节。如果 receive_rewrites 为 true，则输出插件还将针对在某些 DDL 操作期间堆重写所做的更改进行调用。这些更改对于处理 DDL 复制的插件很重要，但它们需要特殊处理。

启动回调应验证 ctx->output_plugin_options 中存在的选项。如果输出插件需要有状态，它可以使用 ctx->output_plugin_private 来存储它。

每当先前处于活动状态的复制槽不再使用时，就会调用可选的 shutdown_cb 回调，并且可以用来释放输出插件的私有资源。该槽不一定正在删除，只是流正在停止。

typedef void (*LogicalDecodeShutdownCB) (struct LogicalDecodingContext *ctx);

每当已提交事务的开始已解码时，就会调用必需的 begin_cb 回调。已中止的事务及其内容永远不会被解码。

typedef void (*LogicalDecodeBeginCB) (struct LogicalDecodingContext *ctx,
                                      ReorderBufferTXN *txn);

txn 参数包含有关事务的元信息，例如已提交的时间戳及其 XID。

每当事务提交已解码时，就会调用必需的 commit_cb 回调。如果存在任何已修改的行，则在之前将调用所有已修改行的 change_cb 回调。

typedef void (*LogicalDecodeCommitCB) (struct LogicalDecodingContext *ctx,
                                       ReorderBufferTXN *txn,
                                       XLogRecPtr commit_lsn);

对于事务中的每个单独行修改，都会调用必需的 change_cb 回调，它可能是 INSERT、UPDATE 或 DELETE。即使原始命令同时修改了几行，也会针对每行单独调用回调。change_cb 回调可以访问系统或用户目录表，以帮助输出行修改详细信息的过程。在解码已准备（但尚未提交）的事务或解码未提交的事务的情况下，此更改回调也可能由于此事务本身同时回滚而出错。在这种情况下，此已中止事务的逻辑解码将正常停止。

typedef void (*LogicalDecodeChangeCB) (struct LogicalDecodingContext *ctx,
                                       ReorderBufferTXN *txn,
                                       Relation relation,
                                       ReorderBufferChange *change);

ctx 和 txn 参数与 begin_cb 和 commit_cb 回调的内容相同，但此外关系描述符 relation 指向行所属的关系，并且描述行修改的结构 change 被传递进来。

可选的 truncate_cb 回调针对 TRUNCATE 命令调用。

typedef void (*LogicalDecodeTruncateCB) (struct LogicalDecodingContext *ctx,
                                         ReorderBufferTXN *txn,
                                         int nrelations,
                                         Relation relations[],
                                         ReorderBufferChange *change);

参数类似于 change_cb 回调。但是，因为通过外键连接的表上的 TRUNCATE 操作需要一起执行，所以此回调接收关系数组，而不仅仅是单个关系。有关详细信息，请参阅 TRUNCATE 语句的描述。

可选的 filter_by_origin_cb 回调被调用以确定从 origin_id 重放的数据是否与输出插件相关。

typedef bool (*LogicalDecodeFilterByOriginCB) (struct LogicalDecodingContext *ctx,
                                               RepOriginId origin_id);

对于其他回调，ctx 参数具有相同的内容。没有信息，但来源可用。要发出信号表明在传入节点上发生的更改不相关，请返回 true，导致它们被过滤掉；否则返回 false。其他回调将不会针对已过滤掉的交易和更改调用。

在实现级联或多向复制解决方案时，这非常有用。按来源筛选可以防止在这样的设置中来回复制相同的更改。虽然交易和更改也携带有关来源的信息，但通过此回调进行筛选明显更有效。

每当解码逻辑解码消息时，都会调用可选的 message_cb 回调。

typedef void (*LogicalDecodeMessageCB) (struct LogicalDecodingContext *ctx,
                                        ReorderBufferTXN *txn,
                                        XLogRecPtr message_lsn,
                                        bool transactional,
                                        const char *prefix,
                                        Size message_size,
                                        const char *message);

txn 参数包含有关交易的元信息，例如已提交的时间戳及其 XID。但是，请注意，当消息是非事务性的并且尚未在记录消息的交易中分配 XID 时，它可以为 NULL。lsn 具有消息的 WAL 位置。transactional 指出消息是否作为事务性消息发送。与更改回调类似，在解码已准备（但尚未提交）的交易或解码未提交的交易的情况下，此消息回调也可能由于此交易本身同时回滚而出错。在这种情况下，此中止交易的逻辑解码将正常停止。prefix 是任意以 null 结尾的前缀，可用于识别当前插件的有趣消息。最后，message 参数保存大小为 message_size 的实际消息。

应格外小心，以确保输出插件认为有趣的前缀是唯一的。使用扩展名或输出插件本身的名称通常是一个不错的选择。

可选的 filter_prepare_cb 回调被调用来确定当前两阶段提交事务的一部分数据是否应该在准备阶段考虑进行解码，还是稍后作为常规单阶段事务在 COMMIT PREPARED 时间进行解码。要表示应该跳过解码，请返回 true；否则返回 false。当未定义回调时，假定为 false（即无筛选，所有使用两阶段提交的事务也分两阶段进行解码）。

typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx,
                                              TransactionId xid,
                                              const char *gid);

对于其他回调，ctx 参数具有相同的内容。参数 xid 和 gid 提供了识别事务的两种不同方式。后来的 COMMIT PREPARED 或 ROLLBACK PREPARED 携带这两个标识符，为输出插件提供了选择要使用什么内容的机会。

可以对每个事务多次调用回调进行解码，并且每次调用时都必须为给定的 xid 和 gid 对提供相同的静态答案。

每当已解码准备事务的开始时，都会调用必需的 begin_prepare_cb 回调。txn 参数的一部分 gid 字段可用于此回调中，以检查插件是否已收到此 PREPARE，在这种情况下，它可以出错或跳过事务的其余更改。

typedef void (*LogicalDecodeBeginPrepareCB) (struct LogicalDecodingContext *ctx,
                                             ReorderBufferTXN *txn);

每当已解码已准备进行两阶段提交的事务时，都会调用必需的 prepare_cb 回调。如果存在任何已修改的行，则在此之前将调用所有已修改行的 change_cb 回调。txn 参数的一部分 gid 字段可用于此回调中。

typedef void (*LogicalDecodePrepareCB) (struct LogicalDecodingContext *ctx,
                                        ReorderBufferTXN *txn,
                                        XLogRecPtr prepare_lsn);

每当已解码事务 COMMIT PREPARED 时，都会调用必需的 commit_prepared_cb 回调。txn 参数的一部分 gid 字段可用于此回调中。

typedef void (*LogicalDecodeCommitPreparedCB) (struct LogicalDecodingContext *ctx,
                                               ReorderBufferTXN *txn,
                                               XLogRecPtr commit_lsn);

每当解码事务 ROLLBACK PREPARED 时，都会调用必需的 rollback_prepared_cb 回调。此回调中可以使用 txn 参数中包含的 gid 字段。可以使用参数 prepare_end_lsn 和 prepare_time 来检查插件是否已收到此 PREPARE TRANSACTION，如果是，则可以应用回滚，否则可以跳过回滚操作。仅 gid 不够，因为下游节点可能具有具有相同标识符的已准备事务。

typedef void (*LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx,
                                                 ReorderBufferTXN *txn,
                                                 XLogRecPtr prepare_end_lsn,
                                                 TimestampTz prepare_time);

在打开正在进行的事务的流式更改块时，将调用必需的 stream_start_cb 回调。

typedef void (*LogicalDecodeStreamStartCB) (struct LogicalDecodingContext *ctx,
                                            ReorderBufferTXN *txn);

在关闭正在进行的事务的流式更改块时，将调用必需的 stream_stop_cb 回调。

typedef void (*LogicalDecodeStreamStopCB) (struct LogicalDecodingContext *ctx,
                                           ReorderBufferTXN *txn);

调用必需的 stream_abort_cb 回调以中止先前流式传输的事务。

typedef void (*LogicalDecodeStreamAbortCB) (struct LogicalDecodingContext *ctx,
                                            ReorderBufferTXN *txn,
                                            XLogRecPtr abort_lsn);

调用 stream_prepare_cb 回调以准备先前流式传输的事务作为两阶段提交的一部分。当输出插件同时支持大型正在进行事务的流式传输和两阶段提交时，需要此回调。

typedef void (*LogicalDecodeStreamPrepareCB) (struct LogicalDecodingContext *ctx,
                                              ReorderBufferTXN *txn,
                                              XLogRecPtr prepare_lsn);

调用必需的 stream_commit_cb 回调以提交先前流式传输的事务。

typedef void (*LogicalDecodeStreamCommitCB) (struct LogicalDecodingContext *ctx,
                                             ReorderBufferTXN *txn,
                                             XLogRecPtr commit_lsn);

在流式更改块中发送更改（由 stream_start_cb 和 stream_stop_cb 调用分隔）时，将调用必需的 stream_change_cb 回调。不显示实际更改，因为事务可能在稍后的时间点中止，并且我们不会为中止的事务解码更改。

typedef void (*LogicalDecodeStreamChangeCB) (struct LogicalDecodingContext *ctx,
                                             ReorderBufferTXN *txn,
                                             Relation relation,
                                             ReorderBufferChange *change);

在流式更改块中发送通用消息（由 stream_start_cb 和 stream_stop_cb 调用分隔）时，将调用可选的 stream_message_cb 回调。不显示事务消息的消息内容，因为事务可能在稍后的时间点中止，并且我们不会为中止的事务解码更改。

typedef void (*LogicalDecodeStreamMessageCB) (struct LogicalDecodingContext *ctx,
                                              ReorderBufferTXN *txn,
                                              XLogRecPtr message_lsn,
                                              bool transactional,
                                              const char *prefix,
                                              Size message_size,
                                              const char *message);

可选的 stream_truncate_cb 回调在流式更改块中的 TRUNCATE 命令中调用（由 stream_start_cb 和 stream_stop_cb 调用分隔）。

typedef void (*LogicalDecodeStreamTruncateCB) (struct LogicalDecodingContext *ctx,
                                               ReorderBufferTXN *txn,
                                               int nrelations,
                                               Relation relations[],
                                               ReorderBufferChange *change);

参数类似于 stream_change_cb 回调。但是，由于需要一起执行通过外键连接的表上的 TRUNCATE 操作，此回调接收关系数组，而不仅仅是单个关系。有关详细信息，请参阅 TRUNCATE 语句的描述。