선택 사항startup_cb콜백은 복제 슬롯이 생성되거나 스트림 변경을 요청할 때마다 호출됩니다.

typedef void ( *logicaldecodestartUpcb) (struct logicaldecodingcontext *ctx,
                                        outputpluginoptions *옵션,
                                        bool is_init);

theis_init복제 슬롯이 생성되고 그렇지 않으면 거짓이 될 때 매개 변수가 사실이 될 것입니다.옵션출력 플러그인이 설정할 수있는 옵션 구조를 가리 킵니다.

typedef struct outputpluginoptions

    outputpluginoutputtype output_type;
    bool leceing_rewrites;
 outputpluginoptions;

output_typeoutput_plugin_textual_output또는output_plugin_binary_output. 참조 참조섹션 47.6.3. 만약에수신 _rewritesTrue, 토토 사이트 순위 플러그인은 특정 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,
                                      REARDERBUFFERTXN *TXN);

theTXN매개 변수는 거래에 대한 메타 정보가 포함되어 있습니다.

필수Commit_CB트랜잭션 커밋이 해독 될 때마다 콜백이 호출됩니다. 그만큼Change_CB수정 된 행이있는 경우 모든 수정 된 행에 대한 콜백이 호출되었습니다.

typedef void ( *logicaldecodecommitcb) (struct logicaldecodingcontext *ctx,
                                       REARDERBUFFERTXN *TXN,
                                       xlogrecptr commit_lsn);

필수Change_CB거래 내의 모든 개별 행 수정에 대해 콜백이 호출됩니다.삽입, 업데이트또는삭제. 원래 명령이 한 번에 여러 행을 수정하더라도 콜백은 각 행에 대해 개별적으로 호출됩니다. 그만큼Change_CB콜백은 시스템 또는 사용자 카탈로그 테이블에 액세스하여 행 수정 세부 사항을 출력하는 프로세스를 지원할 수 있습니다. 준비된 (그러나 아직 커밋되지 않은) 트랜잭션을 디코딩하거나 커밋되지 않은 트랜잭션의 디코딩의 경우이 변경 콜백은이 동일한 트랜잭션의 동시 롤백으로 인해 오류가 발생할 수 있습니다. 이 경우,이 중단 된 거래의 논리적 디코딩은 우아하게 중지됩니다.

typedef void ( *logicaldecodechangecb) (struct logicaldecodingcontext *ctx,
                                       REARDERBUFFERTXN *TXN,
                                       관계 관계,
                                       REARDERBUFFERCHANGE *Change);

theCTXandTXN매개 변수는와 동일한 내용을 갖습니다.begin_cb및Commit_CB콜백, 그러나 또한 관계 설명 자관계행이 속한 관계를 가리키고 구조물변경행 수정을 설명하는 것이 전달됩니다.

선택 사항Truncate_CB콜백이 호출되었습니다Truncate명령.

typedef void ( *logicaldecodetruncatecb) (struct logicaldecodingcontext *ctx,
                                         REARDERBUFFERTXN *TXN,
                                         int nrelations,
                                         관계 관계 [],
                                         REARDERBUFFERCHANGE *Change);

매개 변수는와 유사합니다.Change_CB콜백. 그러나 왜냐하면Truncate외국 키로 연결된 테이블에 대한 조치를 함께 실행해야합니다.이 콜백은 단 하나의 관계 대신 일련의 관계를받습니다. 의 설명을 참조하십시오.Truncate자세한 내용은 진술.

선택 사항filter_by_origin_cb콜백이 호출되어origin_id토토 사이트 순위 플러그인에 관심이 있습니다.

typedef bool ( *logicaldecodefilterbyorigincb) (struct logicaldecodingcontext *ctx,
                                               reporiginid origin_id);

theCTX매개 변수는 다른 콜백과 동일한 내용을 갖습니다. 정보는 없지만 원점을 사용할 수 있습니다. 노드에서 전달 된 변화가 관련이 없다는 것을 알리기 위해, true를 반환하여 필터링됩니다. 그렇지 않으면 거짓. 다른 콜백은 필터링 된 트랜잭션 및 변경에 대해 요구되지 않습니다.

이것은 계단식 또는 다 방향 복제 솔루션을 구현할 때 유용합니다. 원점에 의한 필터링을 사용하면 그러한 설정에서 동일한 변경 사항을 앞뒤로 복제하는 것을 방지 할 수 있습니다. 트랜잭션 및 변경 사항도 원점에 대한 정보를 제공하지만이 콜백을 통한 필터링은 더욱 효율적입니다.

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

typedef void ( *logicaldecodemessagecb) (struct logicaldecodingcontext *ctx,
                                        REARDERBUFFERTXN *TXN,
                                        xlogrecptr message_lsn,
                                        bool transactional,
                                        const char *prefix,
                                        size message_size,
                                        const char *메시지);

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

출력 플러그인이 흥미로운 것으로 간주하는 접두사가 독특하다는 것을 확인하기 위해 추가주의를 기울여야합니다. 확장자 이름 또는 출력 플러그인 자체를 사용하는 것은 종종 좋은 선택입니다.

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

typedef bool ( *logicaldecodefilterprepparecb) (struct logicaldecodingcontext *ctx,
                                              TransactionId XID,
                                              const char *gid);

theCTX매개 변수는 다른 콜백과 동일한 내용을 가지고 있습니다. 매개 변수xidandgid거래를 식별하는 두 가지 다른 방법을 제공합니다. 나중에준비또는롤백 준비토토 사이트 순위 플러그인을 사용하여 사용할 내용의 선택을 제공합니다.

콜백은 트랜잭션 당 여러 번 디코딩하여 디코딩하여 주어진 쌍에 대해 동일한 정적 답변을 제공해야합니다xid및gid전화 할 때마다.

필수begin_prepare_cb준비된 트랜잭션의 시작이 해독 될 때마다 콜백이 호출됩니다. 그만큼gid필드,TXN매개 변수,이 콜백에서 플러그인이 이미 수신되었는지 확인하기 위해이 콜백에서 사용할 수 있습니다준비이 경우 트랜잭션의 나머지 변경 사항을 오류가 발생하거나 건너 뛸 수 있습니다.

typedef void ( *logicaldecodebeginprecb) (struct logicaldecodingcontext *ctx,
                                             REARDERBUFFERTXN *TXN);

필수Prepare_CB콜백은 2 단계 커밋을 위해 준비된 트랜잭션이 해독 될 때마다 호출됩니다. 그만큼Change_CB수정 된 행이 있으면 모든 수정 된 행의 콜백이 호출되었습니다. 그만큼gid필드,이 필드TXN매개 변수,이 콜백에서 사용할 수 있습니다.

typedef void ( *logicaldecodepreparecb) (struct logicaldecodingcontext *ctx,
                                        REARDERBUFFERTXN *TXN,
                                        xlogrecptr repay_lsn);

필수commit_prepared_cb거래 할 때마다 콜백이 호출됩니다준비 준비디코딩되었습니다. 그만큼gid필드,TXN매개 변수,이 콜백에서 사용할 수 있습니다.

typedef void ( *logicaldecodecommitpreparedcb) (struct logicaldecodingcontext *ctx,
                                               REARDERBUFFERTXN *TXN,
                                               xlogrecptr commit_lsn);

필수Rollback_prepared_cb거래 할 때마다 콜백이 호출됩니다롤백 준비디코딩되었습니다. 그만큼gid필드,TXN매개 변수는이 콜백에서 사용할 수 있습니다. 매개 변수repay_end_lsnandPrepare_time플러그인이이를 수신했는지 확인하는 데 사용할 수 있습니다거래 준비이 경우 롤백을 적용 할 수 있습니다. 그렇지 않으면 롤백 작동을 건너 뛸 수 있습니다. 그만큼gid다운 스트림 노드가 동일한 식별자와 준비된 트랜잭션을 가질 수 있기 때문에 충분하지 않습니다.

typedef void ( *logicaldecoderollbackpreparedcb) (struct logicaldecodingcontext *ctx,
                                                 REARDERBUFFERTXN *TXN,
                                                 xlogrecptr repay_end_lsn,
                                                 timestamptz repay_time);

필수Stream_start_cb진행중인 트랜잭션에서 스트리밍 된 변경 블록을 열 때 콜백이 호출됩니다.

typedef void ( *logicalDecodeStreamStartCB) (struct logicaldecodingcontext *ctx,
                                            REARDERBUFFERTXN *TXN);

필수Stream_Stop_CB진행중인 트랜잭션에서 스트리밍 된 변경 블록을 닫을 때 콜백이 호출됩니다.

typedef void ( *logicalDecodeStreamStopcb) (struct logicaldecodingcontext *ctx,
                                           REARDERBUFFERTXN *TXN);

필수Stream_abort_cb콜백은 이전에 스트리밍 된 트랜잭션을 중단하기 위해 호출됩니다.

typedef void ( *logicaldecodestreamabortcb) (struct logicaldecodingcontext *ctx,
                                            REARDERBUFFERTXN *TXN,
                                            xlogrecptr abort_lsn);

theStream_prepare_cb콜백은 2 단계 커밋의 일환으로 이전에 스트리밍 된 트랜잭션을 준비하기 위해 호출됩니다. 이 콜백은 출력 플러그인이 대규모 진행 중 트랜잭션의 스트리밍과 2 단계 커밋을 모두 지원할 때 필요합니다.

typedef void ( *logicalDecodeStreamPreparecb) (struct logicaldecodingcontext *ctx,
                                              REARDERBUFFERTXN *TXN,
                                              xlogrecptr repay_lsn);

필수Stream_commit_cb콜백은 이전에 스트리밍 된 트랜잭션을 커밋하기 위해 호출됩니다.

typedef void ( *logicalDecodeStreamCommitcb) (struct logicaldecodingcontext *ctx,
                                             REARDERBUFFERTXN *TXN,
                                             xlogrecptr commit_lsn);

필수Stream_change_cb스트리밍 된 변경 블록에서 변경을 보낼 때 콜백이 호출됩니다 (Stream_start_cbandStream_Stop_CB전화). 트랜잭션이 나중에 중단 될 수 있으므로 실제 변경 사항은 표시되지 않으며 중단 된 거래의 변경 사항을 해독하지 않습니다.

typedef void ( *logicaldecodestreamchangecb) (struct logicaldecodingcontext *ctx,
                                             REARDERBUFFERTXN *TXN,
                                             관계 관계,
                                             REARDERBUFFERCHANGE *Change);

선택 사항Stream_Message_CB스트리밍 된 변경 블록에서 일반 메시지를 보낼 때 콜백이 호출됩니다 (Stream_start_cb및Stream_Stop_cb전화). 트랜잭션이 나중에 중단 될 수 있으므로 트랜잭션 메시지의 메시지 내용은 표시되지 않으며 중단 된 트랜잭션의 변경 사항을 해독하지 않습니다.

typedef void ( *logicalDecodeStreamMessageCB) (struct logicaldecodingcontext *ctx,
                                              REARDERBUFFERTXN *TXN,
                                              xlogrecptr message_lsn,
                                              bool transactional,
                                              const char *prefix,
                                              size message_size,
                                              const char *메시지);

선택 사항Stream_truncate_cb콜백이 호출되었습니다Truncate스트리밍 된 변경 블록의 명령 (Stream_start_cb및Stream_Stop_CB전화).

typedef void ( *logicalDecodeStreamTruncateCb) (struct logicaldecodingcontext *ctx,
                                               REARDERBUFFERTXN *TXN,
                                               int nrelations,
                                               관계 관계 [],
                                               REARDERBUFFERCHANGE *Change);

매개 변수는와 유사합니다.Stream_change_cb콜백. 그러나 왜냐하면Truncate외국 키로 연결된 테이블의 조치를 함께 실행해야합니다.이 콜백은 단 하나의 관계 대신 일련의 관계를받습니다. 의 설명을 참조하십시오.Truncate자세한 내용은 진술.