每当创建复制槽或请求流式传输更改时，都会调用可选的 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。另请参阅 第 47.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 命令，将调用可选的 truncate_cb 回调函数。

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 回调函数。gid 字段是 txn 参数的一部分，可以在此回调函数中使用，以检查插件是否已收到此 PREPARE，在这种情况下，它可以报错或跳过事务的其余更改。

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

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

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

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

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

每当解码 ROLLBACK PREPARED 事务时，都会调用必需的 rollback_prepared_cb 回调函数。gid 字段是 txn 参数的一部分，可以在此回调函数中使用。参数 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_start_cb 和 stream_stop_cb 调用分隔）中的 TRUNCATE 命令，将调用可选的 stream_truncate_cb 回调函数。

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

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