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

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

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

typedef 구조물 출력 플러그 인노프

    outputpluginoutputtype output_type;
    bool leceing_rewrites;
 outputpluginoptions;

output_type|output_plugin_textual_output또는output_plugin_binary_output. 참조 참조섹션 48.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콜백은 트랜잭션 내의 모든 개별 행 수정에 대해 호출됩니다.삽입, 업데이트또는삭제. 원래 명령이 한 번에 여러 행을 수정하더라도 콜백은 각 행에 대해 개별적으로 호출됩니다.

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

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

theTruncate_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 위치가 있습니다. 그만큼거래메시지가 트랜잭션으로 전송되었는지 여부를 말합니다. 그만큼prefix현재 플러그인에 대한 흥미로운 메시지를 식별하는 데 사용할 수있는 임의의 null 종결 접두사입니다. 그리고 마지막으로메시지매개 변수는 실제 메시지를 보유합니다message_size크기.

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