csv

Documentation

Index

• func NewBatchDecoder(ctx context.Context, codecConfig *common.Config, tableInfo *model.TableInfo, ...) (codec.RowEventDecoder, error)
• func NewTxnEventEncoderBuilder(config *common.Config) codec.TxnEventEncoderBuilder
• type BatchEncoder
  • func (b *BatchEncoder) AppendTxnEvent(e *model.SingleTableTxn, callback func()) error
  • func (b *BatchEncoder) Build() (messages []*common.Message)

Functions

func NewBatchDecoder

func NewBatchDecoder(ctx context.Context,
	codecConfig *common.Config,
	tableInfo *model.TableInfo,
	value []byte,
) (codec.RowEventDecoder, error)

NewBatchDecoder creates a new BatchDecoder

func NewTxnEventEncoderBuilder

func NewTxnEventEncoderBuilder(config *common.Config) codec.TxnEventEncoderBuilder

NewTxnEventEncoderBuilder creates a csv batchEncoderBuilder.

Types

type BatchEncoder

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

BatchEncoder encodes the events into the byte of a batch into.

func (*BatchEncoder) AppendTxnEvent

func (b *BatchEncoder) AppendTxnEvent(
	e *model.SingleTableTxn,
	callback func(),
) error

AppendTxnEvent implements the TxnEventEncoder interface

func (*BatchEncoder) Build

func (b *BatchEncoder) Build() (messages []*common.Message)

Build implements the RowEventEncoder interface