tskv

Documentation

Index

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

Functions

func NewParserTSKV

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

Types

type ParserConfigTSKVCommon

type ParserConfigTSKVCommon struct {
	// common parameters - for lb/kafka/yds/eventhub
	Fields             []abstract.ColSchema
	SchemaResourceName string // for the case, when logfeller-schema-id. Only for internal installation!

	NullKeysAllowed      bool // (title: "Использовать значение NULL в ключевых столбцах", "Разрешить NULL в ключевых колонках")
	AddRest              bool // (title: "Добавить неразмеченные столбцы", usage: "Поля, отсутствующие в схеме, попадут в колонку _rest")
	UnescapeStringValues bool
}

func (*ParserConfigTSKVCommon) IsAppendOnly

func (c *ParserConfigTSKVCommon) IsAppendOnly() bool

func (*ParserConfigTSKVCommon) IsNewParserConfig

func (c *ParserConfigTSKVCommon) IsNewParserConfig()

func (*ParserConfigTSKVCommon) Validate

func (c *ParserConfigTSKVCommon) Validate() error

type ParserConfigTSKVLb

type ParserConfigTSKVLb struct {
	// common parameters - for lb/kafka/yds/eventhub
	Fields             []abstract.ColSchema
	SchemaResourceName string // for the case, when logfeller-schema-id. Only for internal installation!

	NullKeysAllowed      bool // (title: "Использовать значение NULL в ключевых столбцах", "Разрешить NULL в ключевых колонках")
	AddRest              bool // (title: "Добавить неразмеченные столбцы", usage: "Поля, отсутствующие в схеме, попадут в колонку _rest")
	UnescapeStringValues bool

	// special parameters for logbroker-source:
	SkipSystemKeys    bool                   // aka skip_dedupe_keys/SkipDedupeKeys (title: "Пользовательские ключевые столбцы", usage: "При парсинге ключи дедубликации Logbroker не будут добавлены к списку пользовательских ключевых столбцов")
	TimeField         *abstract.TimestampCol // (title: "Столбец, содержащий дату-время")
	AddSystemCols     bool                   // (title: "Добавление системных столбцов Logbroker", usage: "CreateTime (_lb_ctime) WriteTime (_lb_wtime) и все Headers с префиксом _lb_extra_")
	TableSplitter     *abstract.TableSplitter
	IgnoreColumnPaths bool
	DropUnparsed      bool
	MaskSecrets       bool
}

func (*ParserConfigTSKVLb) IsAppendOnly

func (c *ParserConfigTSKVLb) IsAppendOnly() bool

func (*ParserConfigTSKVLb) IsNewParserConfig

func (c *ParserConfigTSKVLb) IsNewParserConfig()

func (*ParserConfigTSKVLb) Validate

func (c *ParserConfigTSKVLb) Validate() error