可选的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。另见Section 48.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。即使原命令一次修改了多行，也会针对每一行单独调用此回调。

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是任意的、以空字符终止的前缀，可用于识别当前插件关注的消息。最后，message参数保存实际消息，其大小为message_size。

应特别注意，确保输出插件视为有意义的消息前缀具有唯一性。使用扩展名或输 出插件自身的名称通常是一个不错的选择。