只要创建复制槽，或者要求某个复制槽开始流式传输更改，就会调用可选的 startup_cb 回调，而不管当前是否已经有准备好输出的更改。

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

当复制槽正在创建时，is_init 参数为真，否则为假。options 指向一个结构体，输出插件可以在其中设置选项：

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

output_type 必须设置为 OUTPUT_PLUGIN_TEXTUAL_OUTPUT 或 OUTPUT_PLUGIN_BINARY_OUTPUT。另见第 48.6.3 节。如果 receive_rewrites 为真，则在某些 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。

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