raw2table

Documentation

Index

• func NewParserRawToTable(inWrapped interface{}, sniff bool, logger log.Logger, ...) (parsers.Parser, error)
• type ParserConfigRawToTableCommon
  • func (c *ParserConfigRawToTableCommon) IsAppendOnly() bool
  • func (c *ParserConfigRawToTableCommon) IsNewParserConfig()
  • func (c *ParserConfigRawToTableCommon) Validate() error
• type ParserConfigRawToTableLb
  • func (c *ParserConfigRawToTableLb) IsAppendOnly() bool
  • func (c *ParserConfigRawToTableLb) IsNewParserConfig()
  • func (c *ParserConfigRawToTableLb) Validate() error

Functions

func NewParserRawToTable

func NewParserRawToTable(inWrapped interface{}, sniff bool, logger log.Logger, registry *stats.SourceStats) (parsers.Parser, error)

Types

type ParserConfigRawToTableCommon

type ParserConfigRawToTableCommon struct {
	IsAddTimestamp bool
	IsAddHeaders   bool
	IsAddKey       bool
	IsKeyString    bool
	IsValueString  bool
	IsTopicAsName  bool
	TableName      string
}

func (*ParserConfigRawToTableCommon) IsAppendOnly

func (c *ParserConfigRawToTableCommon) IsAppendOnly() bool

func (*ParserConfigRawToTableCommon) IsNewParserConfig

func (c *ParserConfigRawToTableCommon) IsNewParserConfig()

func (*ParserConfigRawToTableCommon) Validate

func (c *ParserConfigRawToTableCommon) Validate() error

type ParserConfigRawToTableLb

type ParserConfigRawToTableLb struct {
}

func (*ParserConfigRawToTableLb) IsAppendOnly

func (c *ParserConfigRawToTableLb) IsAppendOnly() bool

func (*ParserConfigRawToTableLb) IsNewParserConfig

func (c *ParserConfigRawToTableLb) IsNewParserConfig()

func (*ParserConfigRawToTableLb) Validate

func (c *ParserConfigRawToTableLb) Validate() error