blank

Documentation

Index

• Constants
• Variables
• func ExtractValue[T any](ci *abstract.ChangeItem, col string) (T, error)
• func NewParserBlank(_ interface{}, _ bool, logger log.Logger, registry *stats.SourceStats) (parsers.Parser, error)
• func NewRawMessage(msg parsers.Message, partition abstract.Partition) abstract.ChangeItem
• type ParserBlank
  • func (p *ParserBlank) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *ParserBlank) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem
• type ParserConfigBlankLb
  • func (c *ParserConfigBlankLb) IsAppendOnly() bool
  • func (c *ParserConfigBlankLb) IsNewParserConfig()
  • func (c *ParserConfigBlankLb) Validate() error

Constants

const (
	PartitionColum   = "partition"
	OffsetColumn     = "offset"
	SeqNoColumn      = "seq_no"
	CreateTimeColumn = "c_time"
	WriteTimeColumn  = "w_time"
	IPColumn         = "ip"
	RawMessageColumn = "lb_raw_message"
	SourceIDColumn   = "source_id"
	ExtrasColumn     = "lb_extra_fields"
)

Variables

var (
	BlankCols    = cols(BlankSchema.Columns())
	BlankColsIDX = colIDX(BlankSchema.Columns())
)

var (
	BlankSchema = abstract.NewTableSchema([]abstract.ColSchema{
		{ColumnName: PartitionColum, PrimaryKey: true, DataType: "string"},
		{ColumnName: OffsetColumn, PrimaryKey: true, DataType: "uint64"},
		{ColumnName: SeqNoColumn, DataType: "uint64"},
		{ColumnName: SourceIDColumn, DataType: "string"},
		{ColumnName: CreateTimeColumn, DataType: "datetime"},
		{ColumnName: WriteTimeColumn, DataType: "datetime"},
		{ColumnName: IPColumn, DataType: "string"},
		{ColumnName: RawMessageColumn, DataType: "string"},
		{ColumnName: ExtrasColumn, DataType: "any"},
	})
)

Functions

func ExtractValue

func ExtractValue[T any](ci *abstract.ChangeItem, col string) (T, error)

func NewParserBlank

func NewParserBlank(_ interface{}, _ bool, logger log.Logger, registry *stats.SourceStats) (parsers.Parser, error)

func NewRawMessage

func NewRawMessage(msg parsers.Message, partition abstract.Partition) abstract.ChangeItem

Types

type ParserBlank

type ParserBlank struct {
}

func (*ParserBlank) Do

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

func (*ParserBlank) DoBatch

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

type ParserConfigBlankLb

type ParserConfigBlankLb struct {
}

func (*ParserConfigBlankLb) IsAppendOnly

func (c *ParserConfigBlankLb) IsAppendOnly() bool

func (*ParserConfigBlankLb) IsNewParserConfig

func (c *ParserConfigBlankLb) IsNewParserConfig()

func (*ParserConfigBlankLb) Validate

func (c *ParserConfigBlankLb) Validate() error