mutate

May 18, 2020

Changes in this version

type Concat

+ Joiner string

type Json

+ DiscardKey bool

+ Extract bool

Aug 20, 2019

Changes in this version

+ const Keep

+ const KeyCase

+ const KeyMode

+ const KeySubEnd

+ const KeySubStart

+ const MicroSecond

+ const MilliSecond

+ const ModeDecode

+ const ModeEncode

+ const ModeLower

+ const ModeUpper

+ const NanoSeconds

+ const Remove

+ const Seconds

+ var OptionCaseKey = Option

+ var OptionCaseMode = Option

+ var OptionKVSplitter = Option

+ var OptionSubEnd = Option

+ var OptionSubStart = Option

+ var OptionURLMode = Option

+ type Case struct

+ CStage string

+ Key string

+ Mode string

+ func (c *Case) ConfigOptions() []Option

+ func (c *Case) Description() string

+ func (c *Case) Init() error

+ func (c *Case) RawTransform(datas []string) ([]string, error)

+ func (c *Case) SampleConfig() string

+ func (c *Case) SetStats(err string) StatsInfo

+ func (c *Case) Stage() string

+ func (c *Case) Stats() StatsInfo

+ func (c *Case) Transform(datas []Data) ([]Data, error)

+ func (c *Case) Type() string

+ type Concat struct

+ Key string

+ New string

+ func (c *Concat) ConfigOptions() []Option

+ func (c *Concat) Description() string

+ func (c *Concat) Init() error

+ func (c *Concat) RawTransform(datas []string) ([]string, error)

+ func (c *Concat) SampleConfig() string

+ func (c *Concat) SetStats(err string) StatsInfo

+ func (c *Concat) Stage() string

+ func (c *Concat) Stats() StatsInfo

+ func (c *Concat) Transform(datas []Data) ([]Data, error)

+ func (c *Concat) Type() string

type Converter

+ func (g *Converter) Init() error

+ type Copy struct

+ Key string

+ New string

+ Override bool

+ func (c *Copy) ConfigOptions() []Option

+ func (c *Copy) Description() string

+ func (c *Copy) Init() error

+ func (c *Copy) RawTransform(datas []string) ([]string, error)

+ func (c *Copy) SampleConfig() string

+ func (c *Copy) SetStats(err string) StatsInfo

+ func (c *Copy) Stage() string

+ func (c *Copy) Stats() StatsInfo

+ func (c *Copy) Transform(datas []Data) ([]Data, error)

+ func (c *Copy) Type() string

+ type Filter struct

+ Key string

+ Mode string

+ Pattern string

+ Regex *regexp.Regexp

+ RemovePattern string

+ StageTime string

+ func (f *Filter) ConfigOptions() []Option

+ func (f *Filter) Description() string

+ func (f *Filter) Init() error

+ func (f *Filter) RawTransform(datas []string) ([]string, error)

+ func (f *Filter) SampleConfig() string

+ func (f *Filter) SetStats(err string) StatsInfo

+ func (f *Filter) Stage() string

+ func (f *Filter) Stats() StatsInfo

+ func (f *Filter) Transform(datas []Data) ([]Data, error)

+ func (f *Filter) Type() string

+ type KV struct

+ DiscardKey bool

+ KeepString bool

+ Key string

+ New string

+ Splitter string

+ func (k *KV) ConfigOptions() []Option

+ func (k *KV) Description() string

+ func (k *KV) Init() error

+ func (k *KV) RawTransform(datas []string) ([]string, error)

+ func (k *KV) SampleConfig() string

+ func (k *KV) SetStats(err string) StatsInfo

+ func (k *KV) Stage() string

+ func (k *KV) Stats() StatsInfo

+ func (k *KV) Transform(datas []Data) ([]Data, error)

+ func (k *KV) Type() string

type Label

+ func (g *Label) Init() error

type Pick

+ func (g *Pick) Init() error

type Spliter

+ ArrayName string

+ ArrayNameNew string

+ SeparateKey string

+ func (g *Spliter) Init() error

+ type Sub struct

+ CStage string

+ End int

+ Key string

+ New string

+ Start int

+ func (s *Sub) ConfigOptions() []Option

+ func (s *Sub) Description() string

+ func (s *Sub) Init() error

+ func (s *Sub) RawTransform(datas []string) ([]string, error)

+ func (s *Sub) SampleConfig() string

+ func (s *Sub) SetStats(err string) StatsInfo

+ func (s *Sub) Stage() string

+ func (s *Sub) Stats() StatsInfo

+ func (s *Sub) Transform(datas []Data) ([]Data, error)

+ func (s *Sub) Type() string

+ type Timestamp struct

+ Key string

+ LayoutBefore string

+ New string

+ Offset int

+ Override bool

+ Precision string

+ func (t *Timestamp) ConfigOptions() []Option

+ func (t *Timestamp) Description() string

+ func (t *Timestamp) Init() error

+ func (t *Timestamp) RawTransform(datas []string) ([]string, error)

+ func (t *Timestamp) SampleConfig() string

+ func (t *Timestamp) SetStats(err string) StatsInfo

+ func (t *Timestamp) Stage() string

+ func (t *Timestamp) Stats() StatsInfo

+ func (t *Timestamp) Transform(datas []Data) ([]Data, error)

+ func (t *Timestamp) Type() string

type Trim

+ func (g *Trim) Init() error

+ type URLConvert struct

+ CStage string

+ Key string

+ Mode string

+ func (u *URLConvert) ConfigOptions() []Option

+ func (u *URLConvert) Description() string

+ func (u *URLConvert) Init() error

+ func (u *URLConvert) RawTransform(datas []string) ([]string, error)

+ func (u *URLConvert) SampleConfig() string

+ func (u *URLConvert) SetStats(err string) StatsInfo

+ func (u *URLConvert) Stage() string

+ func (u *URLConvert) Stats() StatsInfo

+ func (u *URLConvert) Transform(datas []Data) ([]Data, error)

+ func (u *URLConvert) Type() string

type Xml

+ DiscardKey bool

+ Expand bool

+ Keep bool

+ NoAttr bool

Sep 4, 2018

Changes in this version

type Spliter

+ ArraryNameNew string

Jul 30, 2018

Changes in this version

type ArrayExpand

+ func (p *ArrayExpand) Init() error

type Discarder

+ func (g *Discarder) Init() error

type Json

+ func (g *Json) Init() error

type MapReplacer

+ New string

type PandoraKeyConvert

+ func (g *PandoraKeyConvert) Init() error

type Rename

+ NewKey string

+ func (g *Rename) Init() error

type UrlParam

+ SelectKeys string

+ func (p *UrlParam) Init() error

type Xml

+ func (g *Xml) Init() error

Jul 13, 2018

Changes in this version

+ const TYPE

type ArrayExpand

+ func (p *ArrayExpand) SetStats(err string) StatsInfo

type Converter

+ func (g *Converter) SetStats(err string) StatsInfo

type Discarder

+ func (g *Discarder) SetStats(err string) StatsInfo

type Json

+ func (g *Json) SetStats(err string) StatsInfo

type Label

+ func (g *Label) SetStats(err string) StatsInfo

type MapReplacer

+ func (g *MapReplacer) SetStats(err string) StatsInfo

type PandoraKeyConvert

+ func (g *PandoraKeyConvert) SetStats(err string) StatsInfo

+ type Pick struct

+ Key string

+ StageTime string

+ func (g *Pick) ConfigOptions() []Option

+ func (g *Pick) Description() string

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

+ func (g *Pick) SampleConfig() string

+ func (g *Pick) SetStats(err string) StatsInfo

+ func (g *Pick) Stage() string

+ func (g *Pick) Stats() StatsInfo

+ func (g *Pick) Transform(datas []Data) ([]Data, error)

+ func (g *Pick) Type() string

type Rename

+ func (g *Rename) SetStats(err string) StatsInfo

type Replacer

+ func (g *Replacer) SetStats(err string) StatsInfo

type Script

+ Interpreter string

+ func (g *Script) SetStats(err string) StatsInfo

type Spliter

+ func (g *Spliter) SetStats(err string) StatsInfo

type Trim

+ func (g *Trim) SetStats(err string) StatsInfo

type UrlParam

+ func (p *UrlParam) SetStats(err string) StatsInfo

type Xml

+ func (g *Xml) SetStats(err string) StatsInfo

Jun 11, 2018

Changes in this version

type Discarder

+ StageTime string

+ type MapReplacer struct

+ Key string

+ Map string

+ MapFile string

+ func (g *MapReplacer) ConfigOptions() []Option

+ func (g *MapReplacer) Description() string

+ func (g *MapReplacer) Init() error

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

+ func (g *MapReplacer) SampleConfig() string

+ func (g *MapReplacer) Stage() string

+ func (g *MapReplacer) Stats() StatsInfo

+ func (g *MapReplacer) Transform(datas []Data) ([]Data, error)

+ func (g *MapReplacer) Type() string

May 23, 2018

Changes in this version

+ const Both

+ const Prefix

+ const Suffix

+ type DslSchemaEntry struct

+ Default interface{}

+ ElemType string

+ Key string

+ Schema []DslSchemaEntry

+ ValueType string

+ func ParseDsl(dsl string, depth int) (schemas []DslSchemaEntry, err error)

+ type Trim struct

+ Characters string

+ Key string

+ Place string

+ func (g *Trim) ConfigOptions() []Option

+ func (g *Trim) Description() string

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

+ func (g *Trim) SampleConfig() string

+ func (g *Trim) Stage() string

+ func (g *Trim) Stats() StatsInfo

+ func (g *Trim) Transform(datas []Data) ([]Data, error)

+ func (g *Trim) Type() string

Mar 28, 2018

Changes in this version

+ type Xml struct

+ Key string

+ New string

+ func (g *Xml) ConfigOptions() []Option

+ func (g *Xml) Description() string

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

+ func (g *Xml) SampleConfig() string

+ func (g *Xml) Stage() string

+ func (g *Xml) Stats() StatsInfo

+ func (g *Xml) Transform(datas []Data) ([]Data, error)

+ func (g *Xml) Type() string

Mar 14, 2018

Changes in this version

+ type PandoraKeyConvert struct

+ func (g *PandoraKeyConvert) ConfigOptions() []Option

+ func (g *PandoraKeyConvert) Description() string

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

+ func (g *PandoraKeyConvert) SampleConfig() string

+ func (g *PandoraKeyConvert) Stage() string

+ func (g *PandoraKeyConvert) Stats() utils.StatsInfo

+ func (g *PandoraKeyConvert) Transform(datas []Data) ([]Data, error)

+ func (g *PandoraKeyConvert) Type() string

Mar 5, 2018

Changes in this version

+ type Script struct

+ Interprepter string

+ Key string

+ New string

+ Script []byte

+ ScriptPath string

+ func (g *Script) ConfigOptions() []Option

+ func (g *Script) Description() string

+ func (g *Script) Init() error

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

+ func (g *Script) SampleConfig() string

+ func (g *Script) Stage() string

+ func (g *Script) Stats() utils.StatsInfo

+ func (g *Script) Transform(datas []Data) ([]Data, error)

+ func (g *Script) Type() string

Feb 6, 2018

Changes in this version

+ type Json struct

+ Key string

+ New string

+ func (g *Json) ConfigOptions() []Option

+ func (g *Json) Description() string

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

+ func (g *Json) SampleConfig() string

+ func (g *Json) Stage() string

+ func (g *Json) Stats() utils.StatsInfo

+ func (g *Json) Transform(datas []Data) ([]Data, error)

+ func (g *Json) Type() string

Jan 4, 2018

Changes in this version

+ type Label struct

+ Key string

+ Override bool

+ Value string

+ func (g *Label) ConfigOptions() []utils.Option

+ func (g *Label) Description() string

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

+ func (g *Label) SampleConfig() string

+ func (g *Label) Stage() string

+ func (g *Label) Stats() utils.StatsInfo

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

+ func (g *Label) Type() string

Dec 7, 2017

Changes in this version

+ type Rename struct

+ Key string

+ NewKeyName string

+ func (g *Rename) ConfigOptions() []utils.Option

+ func (g *Rename) Description() string

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

+ func (g *Rename) SampleConfig() string

+ func (g *Rename) Stage() string

+ func (g *Rename) Stats() utils.StatsInfo

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

+ func (g *Rename) Type() string

type Replacer

+ Regex bool

+ Regexp *regexp.Regexp

+ func (g *Replacer) Init() error

Nov 22, 2017

Changes in this version

+ type ArrayExpand struct

+ Key string

+ func (p *ArrayExpand) ConfigOptions() []utils.Option

+ func (p *ArrayExpand) Description() string

+ func (p *ArrayExpand) RawTransform(datas []string) ([]string, error)

+ func (p *ArrayExpand) SampleConfig() string

+ func (p *ArrayExpand) Stage() string

+ func (p *ArrayExpand) Stats() utils.StatsInfo

+ func (p *ArrayExpand) Transform(datas []sender.Data) ([]sender.Data, error)

+ func (p *ArrayExpand) Type() string

+ type UrlParam struct

+ Key string

+ func (p *UrlParam) ConfigOptions() []utils.Option

+ func (p *UrlParam) Description() string

+ func (p *UrlParam) RawTransform(datas []string) ([]string, error)

+ func (p *UrlParam) SampleConfig() string

+ func (p *UrlParam) Stage() string

+ func (p *UrlParam) Stats() utils.StatsInfo

+ func (p *UrlParam) Transform(datas []sender.Data) ([]sender.Data, error)

+ func (p *UrlParam) Type() string

Oct 10, 2017

Changes in this version

+ type Converter struct

+ DSL string

+ 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 Spliter struct

+ ArraryName string

+ Key string

+ SeperateKey string

+ 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

Sep 27, 2017

Changes in this version

+ type Discarder struct

+ Key string

+ 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

Sep 5, 2017

Changes in this version

type Replacer

+ func (g *Replacer) Type() string

Aug 29, 2017

Changes in this version

+ type Replacer struct

+ Key string

+ New string

+ Old string

+ StageTime string

+ 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)