선택사항startup_cb복제 슬롯이 생성되거나 내보낼 준비가 된 변경 사항 수에 관계없이 변경 사항 스트리밍을 요청할 때마다 콜백이 호출됩니다.

typedef void (*LogicalDecodeStartupCB) (struct LogicalDecodingContext *ctx,
                                        OutputPluginOptions *옵션,
                                        부울 is_init);

그is_init복제 슬롯이 생성될 때 매개변수는 true이고 그렇지 않으면 false입니다.옵션출력 플러그인이 설정할 수 있는 옵션의 구조를 가리킵니다:

typedef 구조체 OutputPluginOptions

    OutputPluginOutputType 토토 사이트 순위_유형;
    bool receive_rewrites;
 출력 플러그인 옵션;

토토 사이트 순위_유형다음 중 하나로 설정되어야 합니다.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콜백은 트랜잭션 내부의 모든 개별 행 수정에 대해 호출됩니다.삽입, 업데이트, 또는삭제. 원래 명령이 한 번에 여러 행을 수정했더라도 콜백은 각 행에 대해 개별적으로 호출됩니다.change_cb콜백은 행 수정 세부정보를 출력하는 과정을 돕기 위해 시스템 또는 사용자 카탈로그 테이블에 액세스할 수 있습니다. 준비되었지만 아직 커밋되지 않은 트랜잭션을 디코딩하거나 커밋되지 않은 트랜잭션을 디코딩하는 경우 동일한 트랜잭션의 동시 롤백으로 인해 이 변경 콜백이 오류가 발생할 수도 있습니다. 이 경우 중단된 트랜잭션의 논리적 디코딩이 정상적으로 중지됩니다.

typedef void (*LogicalDecodeChangeCB) (struct LogicalDecodingContext *ctx,
                                       ReorderBufferTXN *txn,
                                       관계 관계,
                                       ReorderBufferChange *변경);

그ctx그리고txn매개변수의 내용은 다음과 같습니다.begin_cb그리고commit_cb콜백, 추가로 관계 설명자관계행이 속한 관계와 구조체를 가리킴변경행 수정을 설명하는 내용이 전달되었습니다.

선택사항truncate_cb콜백이 호출됩니다.잘라내기명령.

typedef void (*LogicalDecodeTruncateCB) (struct LogicalDecodingContext *ctx,
                                         ReorderBufferTXN *txn,
                                         정수 관계,
                                         관계관계[],
                                         ReorderBufferChange *변경);

매개변수는 다음과 유사합니다.change_cb콜백. 그러나 왜냐하면잘라내기외래 키로 연결된 테이블에 대한 작업은 함께 실행되어야 하며, 이 콜백은 단일 관계 대신 관계 배열을 수신합니다. 설명을 참조하세요.잘라내기자세한 내용은 성명을 참조하세요.

선택사항filter_by_origin_cb데이터가 재생되었는지 여부를 확인하기 위해 콜백이 호출됩니다.origin_id토토 사이트 순위 플러그인에 관심이 있습니다.

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

그ctx매개변수는 다른 콜백과 동일한 내용을 갖습니다. 정보는 없으나 원산지는 알 수 있습니다. 전달된 노드에서 발생한 변경 사항이 관련이 없다는 신호를 보내려면 true를 반환하여 해당 변경 사항이 필터링되도록 합니다. 그렇지 않으면 거짓입니다. 필터링된 트랜잭션 및 변경 사항에 대해서는 다른 콜백이 호출되지 않습니다.

이는 계단식 또는 다방향 복제 솔루션을 구현할 때 유용합니다. 원본을 기준으로 필터링하면 이러한 설정에서 동일한 변경 사항이 앞뒤로 복제되는 것을 방지할 수 있습니다. 트랜잭션과 변경 사항도 출처에 대한 정보를 전달하지만 이 콜백을 통한 필터링은 눈에 띄게 더 효율적입니다.

선택사항message_cb콜백은 논리적 디코딩 메시지가 디코딩될 때마다 호출됩니다.

typedef void (*LogicalDecodeMessageCB) (struct LogicalDecodingContext *ctx,
                                        ReorderBufferTXN *txn,
                                        XLogRecPtr message_lsn,
                                        부울 트랜잭션,
                                        const char *접두사,
                                        크기 message_size,
                                        const char *메시지);

그txn매개변수에는 커밋된 타임스탬프 및 XID와 같은 트랜잭션에 대한 메타 정보가 포함됩니다. 그러나 메시지가 비트랜잭션이고 메시지를 기록한 트랜잭션에서 XID가 아직 할당되지 않은 경우 NULL이 될 수 있습니다.lsn메시지의 WAL 위치가 있습니다.트랜잭션메시지가 트랜잭션으로 전송되었는지 여부를 나타냅니다. 변경 콜백과 유사하게, 준비된(아직 커밋되지 않은) 트랜잭션을 디코딩하거나 커밋되지 않은 트랜잭션을 디코딩하는 경우 이 메시지 콜백은 동일한 트랜잭션의 동시 롤백으로 인해 오류가 발생할 수도 있습니다. 이 경우 중단된 트랜잭션의 논리적 디코딩이 정상적으로 중지됩니다. 그만큼접두사는 현재 플러그인에 대한 흥미로운 메시지를 식별하는 데 사용할 수 있는 임의의 null 종료 접두사입니다. 그리고 마지막으로메시지매개변수에는 다음의 실제 메시지가 포함됩니다.message_size크기.

출력 플러그인이 관심 있다고 간주하는 접두사가 고유한지 확인하기 위해 특별한 주의를 기울여야 합니다. 확장 프로그램 이름이나 출력 플러그인 자체를 사용하는 것이 좋은 선택인 경우가 많습니다.

선택사항filter_prepare_cb콜백은 현재 2단계 커밋 트랜잭션의 일부인 데이터가 이 준비 단계에서 디코딩을 위해 고려되어야 하는지 또는 나중에 일반 1단계 트랜잭션으로 고려되어야 하는지 결정하기 위해 호출됩니다.커밋 준비됨시간. 디코딩을 건너뛰어야 한다는 신호를 보내려면 다음을 반환하세요.참; 거짓그렇지 않으면. 콜백이 정의되지 않은 경우거짓가정됩니다(즉, 필터링이 없으며 2단계 커밋을 사용하는 모든 트랜잭션도 2단계로 디코딩됩니다).

typedef bool (*LogicalDecodeFilterPrepareCB) (struct LogicalDecodingContext *ctx,
                                              거래 ID xid,
                                              const char *gid);

그ctx매개변수에는 다른 콜백과 동일한 내용이 있습니다. 매개변수xid그리고기드거래를 식별하는 두 가지 다른 방법을 제공합니다. 나중에커밋 준비됨또는롤백 준비됨두 식별자를 모두 전달하여 토토 사이트 순위 플러그인에 사용할 항목을 선택할 수 있습니다.

콜백은 디코딩을 위해 트랜잭션당 여러 번 호출될 수 있으며 주어진 쌍에 대해 동일한 정적 응답을 제공해야 합니다.xid그리고지드호출될 때마다.

필수begin_prepare_cb콜백은 준비된 트랜잭션의 시작이 디코딩될 때마다 호출됩니다.지드필드는의 일부입니다.txn매개변수는 플러그인이 이미 이를 수신했는지 확인하기 위해 이 콜백에서 사용할 수 있습니다.준비이 경우 오류가 발생하거나 트랜잭션의 나머지 변경 사항을 건너뛸 수 있습니다.

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

필수prepare_cb콜백은 2단계 커밋을 위해 준비된 트랜잭션이 디코딩될 때마다 호출됩니다.change_cb33950_34061기드필드(의 일부)txn매개변수는 이 콜백에서 사용될 수 있습니다.

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

필수commit_prepared_cb트랜잭션이 발생할 때마다 콜백이 호출됩니다.커밋 준비됨디코드되었습니다.기드필드는의 일부입니다.txn매개변수는 이 콜백에서 사용될 수 있습니다.

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

필수rollback_prepared_cb트랜잭션이 발생할 때마다 콜백이 호출됩니다.롤백 준비됨디코드되었습니다.지드필드(의 일부)txn매개변수를 이 콜백에서 사용할 수 있습니다. 매개변수prepare_end_lsn그리고prepare_time플러그인이 이를 수신했는지 확인하는 데 사용할 수 있습니다.거래 준비이 경우 롤백을 적용할 수 있고, 그렇지 않으면 롤백 작업을 건너뛸 수 있습니다.기드다운스트림 노드가 동일한 식별자를 가진 준비된 트랜잭션을 가질 수 있으므로 단독으로는 충분하지 않습니다.

typedef void (*LogicalDecodeRollbackPreparedCB) (struct LogicalDecodingContext *ctx,
                                                 ReorderBufferTXN *txn,
                                                 XLogRecPtr prepare_end_lsn,
                                                 타임스탬프Tz 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콜백은 2단계 커밋의 일부로 이전에 스트리밍된 트랜잭션을 준비하기 위해 호출됩니다. 이 콜백은 출력 플러그인이 진행 중인 대규모 트랜잭션의 스트리밍과 2단계 커밋을 모두 지원할 때 필요합니다.

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_change_cb스트리밍된 변경 사항 블록에서 변경 사항을 보낼 때 콜백이 호출됩니다(다음으로 구분됨).stream_start_cb그리고stream_stop_cb호출). 트랜잭션이 나중에 중단될 수 있고 중단된 트랜잭션에 대한 변경 사항은 디코딩되지 않으므로 실제 변경 사항은 표시되지 않습니다.

typedef void (*LogicalDecodeStreamChangeCB) (struct LogicalDecodingContext *ctx,
                                             ReorderBufferTXN *txn,
                                             관계 관계,
                                             ReorderBufferChange *변경);

선택사항stream_message_cb스트리밍된 변경 블록에서 일반 메시지를 보낼 때 콜백이 호출됩니다(다음으로 구분됨).stream_start_cb그리고stream_stop_cb호출). 트랜잭션은 나중에 중단될 수 있고 중단된 트랜잭션에 대한 변경 사항은 디코딩되지 않으므로 트랜잭션 메시지의 메시지 내용은 표시되지 않습니다.

typedef void (*LogicalDecodeStreamMessageCB) (struct LogicalDecodingContext *ctx,
                                              ReorderBufferTXN *txn,
                                              XLogRecPtr message_lsn,
                                              부울 트랜잭션,
                                              const char *접두사,
                                              크기 message_size,
                                              const char *메시지);

선택사항stream_truncate_cb콜백이 다음에 대해 호출되었습니다.잘라내기스트리밍된 변경 블록의 명령(다음으로 구분됨stream_start_cb그리고stream_stop_cb호출).

typedef void (*LogicalDecodeStreamTruncateCB) (struct LogicalDecodingContext *ctx,
                                               ReorderBufferTXN *txn,
                                               정수 관계,
                                               관계관계[],
                                               ReorderBufferChange *변경);

매개변수는 다음과 유사합니다.stream_change_cb콜백. 그러나 왜냐하면잘라내기외래 키로 연결된 테이블에 대한 작업은 함께 실행되어야 하며, 이 콜백은 단일 관계 대신 관계 배열을 수신합니다. 설명을 참조하세요.잘라내기자세한 내용은 설명을 참조하세요.