debezium

Documentation

Index

• func NewBatchEncoderBuilder(config *common.Config, clusterID string) codec.RowEventEncoderBuilder
• type BatchEncoder
  • func (d *BatchEncoder) AppendRowChangedEvent(_ context.Context, _ string, e *model.RowChangedEvent, callback func()) error
  • func (d *BatchEncoder) Build() []*common.Message
  • func (d *BatchEncoder) EncodeCheckpointEvent(ts uint64) (*common.Message, error)
  • func (d *BatchEncoder) EncodeDDLEvent(e *model.DDLEvent) (*common.Message, error)

Functions

func NewBatchEncoderBuilder

func NewBatchEncoderBuilder(config *common.Config, clusterID string) codec.RowEventEncoderBuilder

NewBatchEncoderBuilder creates a Debezium batchEncoderBuilder.

Types

type BatchEncoder

type BatchEncoder struct {
	// contains filtered or unexported fields
}

BatchEncoder encodes message into Debezium format.

func (*BatchEncoder) AppendRowChangedEvent

func (d *BatchEncoder) AppendRowChangedEvent(
	_ context.Context,
	_ string,
	e *model.RowChangedEvent,
	callback func(),
) error

AppendRowChangedEvent implements the RowEventEncoder interface

func (*BatchEncoder) Build

func (d *BatchEncoder) Build() []*common.Message

Build implements the RowEventEncoder interface

func (*BatchEncoder) EncodeCheckpointEvent

func (d *BatchEncoder) EncodeCheckpointEvent(ts uint64) (*common.Message, error)

EncodeCheckpointEvent implements the RowEventEncoder interface

func (*BatchEncoder) EncodeDDLEvent

func (d *BatchEncoder) EncodeDDLEvent(e *model.DDLEvent) (*common.Message, error)

EncodeDDLEvent implements the RowEventEncoder interface DDL message unresolved tso