normalize

type AddConfig struct {
	Fields map[string]interface{} `yaml:"fields,omitempty" validate:"required"`
}

type AddMetaConfig struct {
	Target string `yaml:"target,omitempty" default:"meta"`
}

type AddMetaProcessor struct {
	// contains filtered or unexported fields
}

type AddProcessor struct {
	// contains filtered or unexported fields
}

type Config struct {
	interceptor.ExtensionConfig `yaml:",inline"`
	Processors                  ProcessorConfig `yaml:"processors,omitempty"`
}

type Convert struct {
	From string `yaml:"from,omitempty" validate:"required"`
	To   string `yaml:"to,omitempty" validate:"required"`
}

type ConvertConfig struct {
	Convert []Convert `yaml:"convert,omitempty" validate:"required"`
}

type ConvertProcessor struct {
	// contains filtered or unexported fields
}

type CopyConfig struct {
	Convert []Convert `yaml:"convert,omitempty" validate:"required"`
}

type CopyProcessor struct {
	// contains filtered or unexported fields
}

type DropConfig struct {
	Targets []string `yaml:"targets,omitempty" validate:"required"`
}

type DropProcessor struct {
	// contains filtered or unexported fields
}

type FmtConfig struct {
	Fields map[string]string `yaml:"fields,omitempty" validate:"required"`
}

type FmtProcessor struct {
	// contains filtered or unexported fields
}

type Interceptor struct {
	ProcessorGroup *ProcessorGroup
	MetricContext  *eventbus.NormalizeMetricEvent
	// contains filtered or unexported fields
}

type JsonDecodeConfig struct {
	Target      string `yaml:"target,omitempty" default:"body"`
	IgnoreError bool   `yaml:"ignoreError"`
}

type JsonDecodeProcessor struct {
	// contains filtered or unexported fields
}

type MoveConfig struct {
	Convert []Convert `yaml:"convert,omitempty"`
}

type MoveProcessor struct {
	// contains filtered or unexported fields
}

type Processor interface {
	Init(interceptor *Interceptor)
	Process(e api.Event) error
	GetName() string
}

type ProcessorConfig []map[string]cfg.CommonCfg

type ProcessorGroup struct {
	// contains filtered or unexported fields
}

type RegexConfig struct {
	Target      string `yaml:"target,omitempty" default:"body"`
	Pattern     string `yaml:"pattern,omitempty" validate:"required"`
	UnderRoot   bool   `yaml:"underRoot,omitempty" default:"true"`
	IgnoreError bool   `yaml:"ignoreError"`
}

type RegexProcessor struct {
	// contains filtered or unexported fields
}

type SplitConfig struct {
	Target      string   `yaml:"target,omitempty" default:"body"`
	Separator   string   `yaml:"separator,omitempty" validate:"required"`
	Max         int      `yaml:"max,omitempty" default:"-1"`
	Keys        []string `yaml:"keys,omitempty"`
	IgnoreError bool     `yaml:"ignoreError"`
}

type SplitProcessor struct {
	// contains filtered or unexported fields
}

type TimestampConfig struct {
	Convert []TimestampConvert `yaml:"convert,omitempty"`
}

type TimestampConvert struct {
	From       string `yaml:"from,omitempty" validate:"required"`
	FromLayout string `yaml:"fromLayout,omitempty" validate:"required"`
	ToLayout   string `yaml:"toLayout,omitempty" validate:"required"`
	ToType     string `yaml:"toType,omitempty"`
	// contains filtered or unexported fields
}

type TimestampProcessor struct {
	// contains filtered or unexported fields
}

type UnderRootConfig struct {
	Keys []string `yaml:"keys,omitempty" validate:"required"`
}

type UnderRootProcessor struct {
	// contains filtered or unexported fields
}