mutate

Documentation

Index

• type Converter
  • func (g *Converter) ConfigOptions() []utils.Option
  • func (g *Converter) Description() string
  • func (g *Converter) RawTransform(datas []string) ([]string, error)
  • func (g *Converter) SampleConfig() string
  • func (g *Converter) Stage() string
  • func (g *Converter) Stats() utils.StatsInfo
  • func (g *Converter) Transform(datas []sender.Data) ([]sender.Data, error)
  • func (g *Converter) Type() string
• type Discarder
  • func (g *Discarder) ConfigOptions() []utils.Option
  • func (g *Discarder) Description() string
  • func (g *Discarder) RawTransform(datas []string) ([]string, error)
  • func (g *Discarder) SampleConfig() string
  • func (g *Discarder) Stage() string
  • func (g *Discarder) Stats() utils.StatsInfo
  • func (g *Discarder) Transform(datas []sender.Data) ([]sender.Data, error)
  • func (g *Discarder) Type() string
• type Replacer
  • func (g *Replacer) ConfigOptions() []utils.Option
  • func (g *Replacer) Description() string
  • func (g *Replacer) RawTransform(datas []string) ([]string, error)
  • func (g *Replacer) SampleConfig() string
  • func (g *Replacer) Stage() string
  • func (g *Replacer) Stats() utils.StatsInfo
  • func (g *Replacer) Transform(datas []sender.Data) ([]sender.Data, error)
  • func (g *Replacer) Type() string
• type Spliter
  • func (g *Spliter) ConfigOptions() []utils.Option
  • func (g *Spliter) Description() string
  • func (g *Spliter) RawTransform(datas []string) ([]string, error)
  • func (g *Spliter) SampleConfig() string
  • func (g *Spliter) Stage() string
  • func (g *Spliter) Stats() utils.StatsInfo
  • func (g *Spliter) Transform(datas []sender.Data) ([]sender.Data, error)
  • func (g *Spliter) Type() string

Types

type Converter

type Converter struct {
	DSL string `json:"dsl"`
	// contains filtered or unexported fields
}

func (*Converter) ConfigOptions

func (g *Converter) ConfigOptions() []utils.Option

func (*Converter) Description

func (g *Converter) Description() string

func (*Converter) RawTransform

func (g *Converter) RawTransform(datas []string) ([]string, error)

func (*Converter) SampleConfig

func (g *Converter) SampleConfig() string

func (*Converter) Stage

func (g *Converter) Stage() string

func (*Converter) Stats

func (g *Converter) Stats() utils.StatsInfo

func (*Converter) Transform

func (g *Converter) Transform(datas []sender.Data) ([]sender.Data, error)

func (*Converter) Type

func (g *Converter) Type() string

type Discarder

type Discarder struct {
	Key string `json:"key"`
	// contains filtered or unexported fields
}

func (*Discarder) ConfigOptions

func (g *Discarder) ConfigOptions() []utils.Option

func (*Discarder) Description

func (g *Discarder) Description() string

func (*Discarder) RawTransform

func (g *Discarder) RawTransform(datas []string) ([]string, error)

func (*Discarder) SampleConfig

func (g *Discarder) SampleConfig() string

func (*Discarder) Stage

func (g *Discarder) Stage() string

func (*Discarder) Stats

func (g *Discarder) Stats() utils.StatsInfo

func (*Discarder) Transform

func (g *Discarder) Transform(datas []sender.Data) ([]sender.Data, error)

func (*Discarder) Type

func (g *Discarder) Type() string

type Replacer

type Replacer struct {
	StageTime string `json:"stage"`
	Key       string `json:"key"`
	Old       string `json:"old"`
	New       string `json:"new"`
	// contains filtered or unexported fields
}

func (*Replacer) ConfigOptions

func (g *Replacer) ConfigOptions() []utils.Option

func (*Replacer) Description

func (g *Replacer) Description() string

func (*Replacer) RawTransform

func (g *Replacer) RawTransform(datas []string) ([]string, error)

func (*Replacer) SampleConfig

func (g *Replacer) SampleConfig() string

func (*Replacer) Stage

func (g *Replacer) Stage() string

func (*Replacer) Stats

func (g *Replacer) Stats() utils.StatsInfo

func (*Replacer) Transform

func (g *Replacer) Transform(datas []sender.Data) ([]sender.Data, error)

func (*Replacer) Type

func (g *Replacer) Type() string

type Spliter

type Spliter struct {
	Key         string `json:"key"`
	SeperateKey string `json:"sep"`
	ArraryName  string `json:"newfield"`
	// contains filtered or unexported fields
}

func (*Spliter) ConfigOptions

func (g *Spliter) ConfigOptions() []utils.Option

func (*Spliter) Description

func (g *Spliter) Description() string

func (*Spliter) RawTransform

func (g *Spliter) RawTransform(datas []string) ([]string, error)

func (*Spliter) SampleConfig

func (g *Spliter) SampleConfig() string

func (*Spliter) Stage

func (g *Spliter) Stage() string

func (*Spliter) Stats

func (g *Spliter) Stats() utils.StatsInfo

func (*Spliter) Transform

func (g *Spliter) Transform(datas []sender.Data) ([]sender.Data, error)

func (*Spliter) Type

func (g *Spliter) Type() string