engine

Documentation

Index

• type DebeziumImpl
  • func NewDebeziumImpl(logger log.Logger, schemaRegistry *confluent.SchemaRegistryClient, ...) *DebeziumImpl
  • func (p *DebeziumImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *DebeziumImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem
  • func (p *DebeziumImpl) DoBuf(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) []abstract.ChangeItem
  • func (p *DebeziumImpl) DoOne(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) ([]byte, abstract.ChangeItem)

Types

type DebeziumImpl

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

func NewDebeziumImpl

func NewDebeziumImpl(logger log.Logger, schemaRegistry *confluent.SchemaRegistryClient, threads uint64) *DebeziumImpl

func (*DebeziumImpl) Do

func (p *DebeziumImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem

func (*DebeziumImpl) DoBatch

func (p *DebeziumImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

func (*DebeziumImpl) DoBuf

func (p *DebeziumImpl) DoBuf(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) []abstract.ChangeItem

func (*DebeziumImpl) DoOne

func (p *DebeziumImpl) DoOne(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) ([]byte, abstract.ChangeItem)

DoOne message with multiple debezium events inside. Contains multiple debezium events only if messages are serialized using schema registry and started with magic zero-byte