Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessorSplit ¶
type ProcessorSplit struct {
SplitKey string
SplitSep string
PreserveOthers bool
NoKeyError bool
EnableLogPositionMeta bool
// contains filtered or unexported fields
}
func (*ProcessorSplit) Description ¶
func (*ProcessorSplit) Description() string
func (*ProcessorSplit) Init ¶
func (p *ProcessorSplit) Init(context pipeline.Context) error
Init called for init some system resources, like socket, mutex...
func (*ProcessorSplit) Process ¶ added in v1.4.0
func (p *ProcessorSplit) Process(in *models.PipelineGroupEvents, context pipeline.PipelineContext)
func (*ProcessorSplit) ProcessLogs ¶
func (p *ProcessorSplit) ProcessLogs(logArray []*protocol.Log) []*protocol.Log
Source Files
Click to show internal directories.
Click to hide internal directories.