嘉興企業建站

可選的filter_by_origin_cb回調被用來 決定從origin_id重放的數據是否是 輸出插件感興趣的數據。

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

ctx參數具有和其他回調相同的內容。 對這個回調只有復制源的信息可用。要標志傳進來的節點上發生的 更改是無關的，返回真，這會導致這些更改被過濾掉，否則返回假。 對于被過濾掉的事務和更改將不會調用其他回調。

在實現級聯或者多向復制方案時，這個回調可以派上用場。用源頭 過濾允許阻止在這樣的設置下來回地復制同樣的更改。雖然事務和 更改也攜帶了有關源頭的信息，通過這個回調過濾明顯更有效些。

只要一個邏輯解碼消息被解碼出來，可選的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的消息。

應該格外小心確保輸出插件用于標識感興趣消息的前綴是唯一的。建議使用擴展或者輸出插件本身的名稱。