engine

Documentation

Index

• Constants
• type RawToTableImpl
  • func NewRawToTable(logger log.Logger, ...) *RawToTableImpl
  • func NewRawToTableDLQ(logger log.Logger, tableName string) *RawToTableImpl
  • func (p *RawToTableImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *RawToTableImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

Constants

const (
	ColNameTopic     = "topic"
	ColNamePartition = "partition"
	ColNameOffset    = "offset"
	ColNameTimestamp = "timestamp"
	Headers          = "headers"
	ColNameKey       = "key"
	ColNameValue     = "value"
)

Types

type RawToTableImpl

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

func NewRawToTable

func NewRawToTable(logger log.Logger, isAddTimestamp, isAddHeaders, isAddKey, isKeyString, isValueString, isTopicAsName bool, tableName string) *RawToTableImpl

func NewRawToTableDLQ

func NewRawToTableDLQ(logger log.Logger, tableName string) *RawToTableImpl

func (*RawToTableImpl) Do

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

func (*RawToTableImpl) DoBatch

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