lfstaging

Documentation

Index

• func NewSinker(cfg *ytcommon.LfStagingDestination, jobIndex int, transfer *model.Transfer, ...) (abstract.Sinker, error)
• type RawMessage
  • func GetRawMessage(ci abstract.ChangeItem) (RawMessage, error)

Functions

func NewSinker

func NewSinker(
	cfg *ytcommon.LfStagingDestination,
	jobIndex int,
	transfer *model.Transfer,
	logger log.Logger,
) (abstract.Sinker, error)

Types

type RawMessage

type RawMessage struct {
	Table     string
	Topic     string
	Partition int32
	SeqNo     int64
	WriteTime time.Time
	Data      []byte
}

func GetRawMessage

func GetRawMessage(ci abstract.ChangeItem) (RawMessage, error)