char

Documentation

Index

• type ProcessorSplitChar
  • func (*ProcessorSplitChar) Description() string
  • func (p *ProcessorSplitChar) Init(context pipeline.Context) error
  • func (p *ProcessorSplitChar) ProcessLogs(logArray []*protocol.Log) []*protocol.Log

Types

type ProcessorSplitChar

type ProcessorSplitChar struct {
	Quote                  string
	QuoteFlag              bool
	SplitSep               string
	SplitKeys              []string
	SourceKey              string
	PreserveOthers         bool
	NoKeyError             bool
	NoMatchError           bool
	KeepSource             bool
	KeepSourceIfParseError bool
	// contains filtered or unexported fields
}

ProcessorSplitChar is a processor plugin to split field (SourceKey) with SplitSep (single byte) and reinsert extracted values into log with SplitKeys. Quote can be used if there are SplitSep in values to extract. If QuoteFlag is set and Quote is used, value of the key should be enclosed by Quote, for example (quote: ", SplitSep: ,), abc,"bcd""" is ok but abc,bc"d""" is not supported. If PreserveOthers is set, it will insert the remainder bytes (after splitting) into log with key '_split_preserve_' instead of dropping them.

func (*ProcessorSplitChar) Description

func (*ProcessorSplitChar) Description() string

func (*ProcessorSplitChar) Init

func (p *ProcessorSplitChar) Init(context pipeline.Context) error

Init called for init some system resources, like socket, mutex...

func (*ProcessorSplitChar) ProcessLogs

func (p *ProcessorSplitChar) ProcessLogs(logArray []*protocol.Log) []*protocol.Log