native

Documentation

Index

• func NewParserNative(_ interface{}, _ bool, logger log.Logger, _ *stats.SourceStats) (parsers.Parser, error)
• type ParserConfigNativeLb
  • func (c *ParserConfigNativeLb) IsAppendOnly() bool
  • func (c *ParserConfigNativeLb) IsNewParserConfig()
  • func (c *ParserConfigNativeLb) Validate() error
• type ParserNative
  • func (p *ParserNative) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *ParserNative) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

Functions

func NewParserNative

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

Types

type ParserConfigNativeLb

type ParserConfigNativeLb struct {
}

func (*ParserConfigNativeLb) IsAppendOnly

func (c *ParserConfigNativeLb) IsAppendOnly() bool

func (*ParserConfigNativeLb) IsNewParserConfig

func (c *ParserConfigNativeLb) IsNewParserConfig()

func (*ParserConfigNativeLb) Validate

func (c *ParserConfigNativeLb) Validate() error

type ParserNative

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

func (*ParserNative) Do

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

func (*ParserNative) DoBatch

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