| 733 | } |
| 734 | |
| 735 | static void |
| 736 | pg_decode_message(LogicalDecodingContext *ctx, |
| 737 | ReorderBufferTXN *txn, XLogRecPtr lsn, bool transactional, |
| 738 | const char *prefix, Size sz, const char *message) |
| 739 | { |
| 740 | OutputPluginPrepareWrite(ctx, true); |
| 741 | appendStringInfo(ctx->out, "message: transactional: %d prefix: %s, sz: %zu content:", |
| 742 | transactional, prefix, sz); |
| 743 | appendBinaryStringInfo(ctx->out, message, sz); |
| 744 | OutputPluginWrite(ctx, true); |
| 745 | } |
| 746 | |
| 747 | static void |
| 748 | pg_decode_stream_start(LogicalDecodingContext *ctx, |
nothing calls this directly
no test coverage detected