tskv

package
v0.0.0-rc7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL