json

Documentation

Index

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

Functions

func NewParserJSON

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

Types

type ParserConfigJSONCommon

type ParserConfigJSONCommon 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

	// private option
	AddDedupeKeys     bool
	UseNumbersInAny   bool
	UnpackBytesBase64 bool
}

func (*ParserConfigJSONCommon) IsAppendOnly

func (c *ParserConfigJSONCommon) IsAppendOnly() bool

func (*ParserConfigJSONCommon) IsNewParserConfig

func (c *ParserConfigJSONCommon) IsNewParserConfig()

func (*ParserConfigJSONCommon) Validate

func (c *ParserConfigJSONCommon) Validate() error

type ParserConfigJSONLb

type ParserConfigJSONLb 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

	// private option
	UseNumbersInAny bool
}

func (*ParserConfigJSONLb) IsAppendOnly

func (c *ParserConfigJSONLb) IsAppendOnly() bool

func (*ParserConfigJSONLb) IsNewParserConfig

func (c *ParserConfigJSONLb) IsNewParserConfig()

func (*ParserConfigJSONLb) Validate

func (c *ParserConfigJSONLb) Validate() error