Documentation
¶
Index ¶
- Constants
- Variables
- type ArrayExpand
- func (p *ArrayExpand) ConfigOptions() []Option
- func (p *ArrayExpand) Description() string
- func (p *ArrayExpand) Init() error
- func (p *ArrayExpand) RawTransform(datas []string) ([]string, error)
- func (p *ArrayExpand) SampleConfig() string
- func (p *ArrayExpand) SetStats(err string) StatsInfo
- func (p *ArrayExpand) Stage() string
- func (p *ArrayExpand) Stats() StatsInfo
- func (p *ArrayExpand) Transform(datas []Data) ([]Data, error)
- func (p *ArrayExpand) Type() string
- type Case
- 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
- 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) ConfigOptions() []Option
- func (g *Converter) Description() string
- func (g *Converter) Init() error
- func (g *Converter) RawTransform(datas []string) ([]string, error)
- func (g *Converter) SampleConfig() string
- func (g *Converter) SetStats(err string) StatsInfo
- func (g *Converter) Stage() string
- func (g *Converter) Stats() StatsInfo
- func (g *Converter) Transform(datas []Data) ([]Data, error)
- func (g *Converter) Type() string
- type Copy
- 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 Discarder
- func (g *Discarder) ConfigOptions() []Option
- func (g *Discarder) Description() string
- func (g *Discarder) Init() error
- func (g *Discarder) RawTransform(datas []string) ([]string, error)
- func (g *Discarder) SampleConfig() string
- func (g *Discarder) SetStats(err string) StatsInfo
- func (g *Discarder) Stage() string
- func (g *Discarder) Stats() StatsInfo
- func (g *Discarder) Transform(datas []Data) ([]Data, error)
- func (g *Discarder) Type() string
- type DslSchemaEntry
- type Filter
- 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 Json
- func (g *Json) ConfigOptions() []Option
- func (g *Json) Description() string
- func (g *Json) Init() error
- func (g *Json) RawTransform(datas []string) ([]string, error)
- func (g *Json) SampleConfig() string
- func (g *Json) SetStats(err string) StatsInfo
- func (g *Json) Stage() string
- func (g *Json) Stats() StatsInfo
- func (g *Json) Transform(datas []Data) ([]Data, error)
- func (g *Json) Type() string
- type KV
- 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) ConfigOptions() []Option
- func (g *Label) Description() string
- func (g *Label) Init() error
- func (g *Label) RawTransform(datas []string) ([]string, error)
- func (g *Label) SampleConfig() string
- func (g *Label) SetStats(err string) StatsInfo
- func (g *Label) Stage() string
- func (g *Label) Stats() StatsInfo
- func (g *Label) Transform(datas []Data) ([]Data, error)
- func (g *Label) Type() string
- type MapReplacer
- 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) SetStats(err string) StatsInfo
- func (g *MapReplacer) Stage() string
- func (g *MapReplacer) Stats() StatsInfo
- func (g *MapReplacer) Transform(datas []Data) ([]Data, error)
- func (g *MapReplacer) Type() string
- type PandoraKeyConvert
- func (g *PandoraKeyConvert) ConfigOptions() []Option
- func (g *PandoraKeyConvert) Description() string
- func (g *PandoraKeyConvert) Init() error
- func (g *PandoraKeyConvert) RawTransform(datas []string) ([]string, error)
- func (g *PandoraKeyConvert) SampleConfig() string
- func (g *PandoraKeyConvert) SetStats(err string) StatsInfo
- func (g *PandoraKeyConvert) Stage() string
- func (g *PandoraKeyConvert) Stats() StatsInfo
- func (g *PandoraKeyConvert) Transform(datas []Data) ([]Data, error)
- func (g *PandoraKeyConvert) Type() string
- type Pick
- func (g *Pick) ConfigOptions() []Option
- func (g *Pick) Description() string
- func (g *Pick) Init() error
- 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) ConfigOptions() []Option
- func (g *Rename) Description() string
- func (g *Rename) Init() error
- func (g *Rename) RawTransform(datas []string) ([]string, error)
- func (g *Rename) SampleConfig() string
- func (g *Rename) SetStats(err string) StatsInfo
- func (g *Rename) Stage() string
- func (g *Rename) Stats() StatsInfo
- func (g *Rename) Transform(datas []Data) ([]Data, error)
- func (g *Rename) Type() string
- type Replacer
- func (g *Replacer) ConfigOptions() []Option
- func (g *Replacer) Description() string
- func (g *Replacer) Init() error
- func (g *Replacer) RawTransform(datas []string) ([]string, error)
- func (g *Replacer) SampleConfig() string
- func (g *Replacer) SetStats(err string) StatsInfo
- func (g *Replacer) Stage() string
- func (g *Replacer) Stats() StatsInfo
- func (g *Replacer) Transform(datas []Data) ([]Data, error)
- func (g *Replacer) Type() string
- type Script
- 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) SetStats(err string) StatsInfo
- func (g *Script) Stage() string
- func (g *Script) Stats() StatsInfo
- func (g *Script) Transform(datas []Data) ([]Data, error)
- func (g *Script) Type() string
- type Spliter
- func (g *Spliter) ConfigOptions() []Option
- func (g *Spliter) Description() string
- func (g *Spliter) Init() error
- func (g *Spliter) RawTransform(datas []string) ([]string, error)
- func (g *Spliter) SampleConfig() string
- func (g *Spliter) SetStats(err string) StatsInfo
- func (g *Spliter) Stage() string
- func (g *Spliter) Stats() StatsInfo
- func (g *Spliter) Transform(datas []Data) ([]Data, error)
- func (g *Spliter) Type() string
- type Sub
- 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
- 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) ConfigOptions() []Option
- func (g *Trim) Description() string
- func (g *Trim) Init() error
- func (g *Trim) RawTransform(datas []string) ([]string, error)
- func (g *Trim) SampleConfig() string
- func (g *Trim) SetStats(err string) StatsInfo
- func (g *Trim) Stage() string
- func (g *Trim) Stats() StatsInfo
- func (g *Trim) Transform(datas []Data) ([]Data, error)
- func (g *Trim) Type() string
- type URLConvert
- 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 UrlParam
- func (p *UrlParam) ConfigOptions() []Option
- func (p *UrlParam) Description() string
- func (p *UrlParam) Init() error
- func (p *UrlParam) RawTransform(datas []string) ([]string, error)
- func (p *UrlParam) SampleConfig() string
- func (p *UrlParam) SetStats(err string) StatsInfo
- func (p *UrlParam) Stage() string
- func (p *UrlParam) Stats() StatsInfo
- func (p *UrlParam) Transform(datas []Data) ([]Data, error)
- func (p *UrlParam) Type() string
- type Xml
- func (g *Xml) ConfigOptions() []Option
- func (g *Xml) Description() string
- func (g *Xml) Init() error
- func (g *Xml) RawTransform(datas []string) ([]string, error)
- func (g *Xml) SampleConfig() string
- func (g *Xml) SetStats(err string) StatsInfo
- func (g *Xml) Stage() string
- func (g *Xml) Stats() StatsInfo
- func (g *Xml) Transform(datas []Data) ([]Data, error)
- func (g *Xml) Type() string
Constants ¶
View Source
const ( ModeUpper = "upper" ModeLower = "lower" KeyCase = "key" KeyMode = "mode" )
View Source
const ( Keep = "keep" Remove = "remove" )
View Source
const ( KeySubStart = "start" KeySubEnd = "end" )
View Source
const ( Seconds = "seconds" MilliSecond = "milliseconds" MicroSecond = "microseconds" NanoSeconds = "nanoseconds" )
View Source
const ( Prefix = "prefix" Suffix = "suffix" Both = "both" )
View Source
const ( ModeDecode = "decode" ModeEncode = "encode" )
View Source
const TYPE = "pick"
Variables ¶
View Source
var ( OptionCaseKey = Option{ KeyName: KeyCase, ChooseOnly: false, Default: "", Required: true, Placeholder: "my_field_keyname", DefaultNoUse: true, Description: "需要进行大小写转换的键(" + KeyCase + ")", ToolTip: "对该字段的值进行大小写转换", Type: transforms.TransformTypeString, } OptionCaseMode = Option{ KeyName: KeyMode, ChooseOnly: true, ChooseOptions: []interface{}{ModeUpper, ModeLower}, Default: ModeLower, Required: true, DefaultNoUse: false, Description: "转换模式(" + KeyMode + ")", } )
View Source
var ( OptionSubStart = Option{ KeyName: KeySubStart, ChooseOnly: false, Required: false, Default: 0, Placeholder: "0", Element: InputNumber, DefaultNoUse: true, Description: "字段提取的起始位置(start)", ToolTip: "指定需要提取字段起始元素的位置(包含)默认为0。不支持负数", Type: transforms.TransformTypeLong, } OptionSubEnd = Option{ KeyName: KeySubEnd, ChooseOnly: false, Required: false, Default: 1, Placeholder: "1", Element: InputNumber, DefaultNoUse: true, Description: "字段提取的结束位置(end)", ToolTip: "指定需要提取字段结束元素的位置(不包含)默认为1。不支持负数", Type: transforms.TransformTypeLong, } )
View Source
var ( OptionKVSplitter = Option{ KeyName: "splitter", ChooseOnly: false, Default: "=", Required: false, Placeholder: "my_field_splitter", DefaultNoUse: true, Description: "分隔符", ToolTip: "使用该分隔符分隔键值对", Type: transforms.TransformTypeString, } )
View Source
var ( OptionURLMode = Option{ KeyName: KeyMode, ChooseOnly: true, ChooseOptions: []interface{}{ModeDecode, ModeEncode}, Default: ModeDecode, Required: true, DefaultNoUse: false, Description: "url decode或encode", } )
Functions ¶
This section is empty.
Types ¶
type ArrayExpand ¶ added in v1.3.6
type ArrayExpand struct { Key string `json:"key"` // contains filtered or unexported fields }
func (*ArrayExpand) ConfigOptions ¶ added in v1.3.6
func (p *ArrayExpand) ConfigOptions() []Option
func (*ArrayExpand) Description ¶ added in v1.3.6
func (p *ArrayExpand) Description() string
func (*ArrayExpand) Init ¶ added in v1.5.2
func (p *ArrayExpand) Init() error
func (*ArrayExpand) RawTransform ¶ added in v1.3.6
func (p *ArrayExpand) RawTransform(datas []string) ([]string, error)
func (*ArrayExpand) SampleConfig ¶ added in v1.3.6
func (p *ArrayExpand) SampleConfig() string
func (*ArrayExpand) SetStats ¶ added in v1.5.1
func (p *ArrayExpand) SetStats(err string) StatsInfo
func (*ArrayExpand) Stage ¶ added in v1.3.6
func (p *ArrayExpand) Stage() string
func (*ArrayExpand) Stats ¶ added in v1.3.6
func (p *ArrayExpand) Stats() StatsInfo
func (*ArrayExpand) Transform ¶ added in v1.3.6
func (p *ArrayExpand) Transform(datas []Data) ([]Data, error)
func (*ArrayExpand) Type ¶ added in v1.3.6
func (p *ArrayExpand) Type() string
type Case ¶ added in v1.5.4
type Case struct { Mode string `json:"mode"` Key string `json:"key"` CStage string `json:"stage"` // contains filtered or unexported fields }
func (*Case) ConfigOptions ¶ added in v1.5.4
func (c *Case) ConfigOptions() []Option
func (*Case) Description ¶ added in v1.5.4
func (*Case) RawTransform ¶ added in v1.5.4
func (*Case) SampleConfig ¶ added in v1.5.4
type Concat ¶ added in v1.5.4
type Concat struct { Key string `json:"key"` New string `json:"new"` Joiner string `json:"joiner"` // contains filtered or unexported fields }
func (*Concat) ConfigOptions ¶ added in v1.5.4
func (c *Concat) ConfigOptions() []Option
func (*Concat) Description ¶ added in v1.5.4
func (*Concat) RawTransform ¶ added in v1.5.4
func (*Concat) SampleConfig ¶ added in v1.5.4
type Converter ¶ added in v1.3.3
type Converter struct { DSL string `json:"dsl"` // contains filtered or unexported fields }
func (*Converter) ConfigOptions ¶ added in v1.3.3
func (g *Converter) ConfigOptions() []Option
func (*Converter) Description ¶ added in v1.3.3
func (*Converter) RawTransform ¶ added in v1.3.3
func (*Converter) SampleConfig ¶ added in v1.3.3
type Copy ¶ added in v1.5.4
type Copy struct { Key string `json:"key"` New string `json:"new"` Override bool `json:"override"` // contains filtered or unexported fields }
func (*Copy) ConfigOptions ¶ added in v1.5.4
func (c *Copy) ConfigOptions() []Option
func (*Copy) Description ¶ added in v1.5.4
func (*Copy) RawTransform ¶ added in v1.5.4
func (*Copy) SampleConfig ¶ added in v1.5.4
type Discarder ¶ added in v1.3.2
type Discarder struct { Key string `json:"key"` StageTime string `json:"stage"` // contains filtered or unexported fields }
func (*Discarder) ConfigOptions ¶ added in v1.3.2
func (g *Discarder) ConfigOptions() []Option
func (*Discarder) Description ¶ added in v1.3.2
func (*Discarder) RawTransform ¶ added in v1.3.2
func (*Discarder) SampleConfig ¶ added in v1.3.2
type DslSchemaEntry ¶ added in v1.4.8
type DslSchemaEntry struct { Key string `json:"key"` ValueType string `json:"valtype"` Default interface{} `json:"default,omitempty"` ElemType string `json:"elemtype,omitempty"` Schema []DslSchemaEntry `json:"schema,omitempty"` }
type Filter ¶ added in v1.5.4
type Filter struct { Key string `json:"key"` StageTime string `json:"stage"` Mode string `json:"mode"` Pattern string `json:"pattern"` RemovePattern string `json:"remove_pattern"` Regex *regexp.Regexp // contains filtered or unexported fields }
func (*Filter) ConfigOptions ¶ added in v1.5.4
func (f *Filter) ConfigOptions() []Option
func (*Filter) Description ¶ added in v1.5.4
func (*Filter) RawTransform ¶ added in v1.5.4
func (*Filter) SampleConfig ¶ added in v1.5.4
type Json ¶ added in v1.4.3
type Json struct { Key string `json:"key"` New string `json:"new"` Extract bool `json:"extract"` DiscardKey bool `json:"discard_key"` // contains filtered or unexported fields }
func (*Json) ConfigOptions ¶ added in v1.4.3
func (g *Json) ConfigOptions() []Option
func (*Json) Description ¶ added in v1.4.3
func (*Json) RawTransform ¶ added in v1.4.3
func (*Json) SampleConfig ¶ added in v1.4.3
type KV ¶ added in v1.5.4
type KV struct { Key string `json:"key"` New string `json:"new"` Splitter string `json:"splitter"` KeepString bool `json:"keep_string"` DiscardKey bool `json:"discard_key"` // contains filtered or unexported fields }
func (*KV) ConfigOptions ¶ added in v1.5.4
func (k *KV) ConfigOptions() []Option
func (*KV) Description ¶ added in v1.5.4
func (*KV) RawTransform ¶ added in v1.5.4
func (*KV) SampleConfig ¶ added in v1.5.4
type Label ¶ added in v1.4.2
type Label struct { Key string `json:"key"` Value string `json:"value"` Override bool `json:"override"` // contains filtered or unexported fields }
func (*Label) ConfigOptions ¶ added in v1.4.2
func (g *Label) ConfigOptions() []Option
func (*Label) Description ¶ added in v1.4.2
func (*Label) RawTransform ¶ added in v1.4.2
func (*Label) SampleConfig ¶ added in v1.4.2
type MapReplacer ¶ added in v1.5.0
type MapReplacer struct { Key string `json:"key"` Map string `json:"map"` MapFile string `json:"map_file"` New string `json:"new"` // contains filtered or unexported fields }
func (*MapReplacer) ConfigOptions ¶ added in v1.5.0
func (g *MapReplacer) ConfigOptions() []Option
func (*MapReplacer) Description ¶ added in v1.5.0
func (g *MapReplacer) Description() string
func (*MapReplacer) Init ¶ added in v1.5.0
func (g *MapReplacer) Init() error
func (*MapReplacer) RawTransform ¶ added in v1.5.0
func (g *MapReplacer) RawTransform(datas []string) ([]string, error)
func (*MapReplacer) SampleConfig ¶ added in v1.5.0
func (g *MapReplacer) SampleConfig() string
func (*MapReplacer) SetStats ¶ added in v1.5.1
func (g *MapReplacer) SetStats(err string) StatsInfo
func (*MapReplacer) Stage ¶ added in v1.5.0
func (g *MapReplacer) Stage() string
func (*MapReplacer) Stats ¶ added in v1.5.0
func (g *MapReplacer) Stats() StatsInfo
func (*MapReplacer) Transform ¶ added in v1.5.0
func (g *MapReplacer) Transform(datas []Data) ([]Data, error)
func (*MapReplacer) Type ¶ added in v1.5.0
func (g *MapReplacer) Type() string
type PandoraKeyConvert ¶ added in v1.4.5
type PandoraKeyConvert struct {
// contains filtered or unexported fields
}
func (*PandoraKeyConvert) ConfigOptions ¶ added in v1.4.5
func (g *PandoraKeyConvert) ConfigOptions() []Option
func (*PandoraKeyConvert) Description ¶ added in v1.4.5
func (g *PandoraKeyConvert) Description() string
func (*PandoraKeyConvert) Init ¶ added in v1.5.2
func (g *PandoraKeyConvert) Init() error
func (*PandoraKeyConvert) RawTransform ¶ added in v1.4.5
func (g *PandoraKeyConvert) RawTransform(datas []string) ([]string, error)
func (*PandoraKeyConvert) SampleConfig ¶ added in v1.4.5
func (g *PandoraKeyConvert) SampleConfig() string
func (*PandoraKeyConvert) SetStats ¶ added in v1.5.1
func (g *PandoraKeyConvert) SetStats(err string) StatsInfo
func (*PandoraKeyConvert) Stage ¶ added in v1.4.5
func (g *PandoraKeyConvert) Stage() string
func (*PandoraKeyConvert) Stats ¶ added in v1.4.5
func (g *PandoraKeyConvert) Stats() StatsInfo
func (*PandoraKeyConvert) Transform ¶ added in v1.4.5
func (g *PandoraKeyConvert) Transform(datas []Data) ([]Data, error)
func (*PandoraKeyConvert) Type ¶ added in v1.4.5
func (g *PandoraKeyConvert) Type() string
type Pick ¶ added in v1.5.1
type Pick struct { Key string `json:"key"` StageTime string `json:"stage"` // contains filtered or unexported fields }
func (*Pick) ConfigOptions ¶ added in v1.5.1
func (g *Pick) ConfigOptions() []Option
func (*Pick) Description ¶ added in v1.5.1
func (*Pick) RawTransform ¶ added in v1.5.1
func (*Pick) SampleConfig ¶ added in v1.5.1
type Rename ¶ added in v1.4.1
type Rename struct { Key string `json:"key"` NewKeyName string `json:"new_key_name"` NewKey string `json:"new"` // contains filtered or unexported fields }
func (*Rename) ConfigOptions ¶ added in v1.4.1
func (g *Rename) ConfigOptions() []Option
func (*Rename) Description ¶ added in v1.4.1
func (*Rename) RawTransform ¶ added in v1.4.1
func (*Rename) SampleConfig ¶ added in v1.4.1
type Replacer ¶
type Replacer struct { StageTime string `json:"stage"` Key string `json:"key"` Old string `json:"old"` New string `json:"new"` Regex bool `json:"regex"` Regexp *regexp.Regexp // contains filtered or unexported fields }
func (*Replacer) ConfigOptions ¶ added in v1.3.2
func (g *Replacer) ConfigOptions() []Option
func (*Replacer) Description ¶
func (*Replacer) SampleConfig ¶
type Script ¶ added in v1.4.4
type Script struct { Key string `json:"key"` New string `json:"new"` Interpreter string `json:"interprepter"` ScriptPath string `json:"scriptpath"` Script string `json:"script"` // contains filtered or unexported fields }
Script represents a transform to run a script.
func (*Script) ConfigOptions ¶ added in v1.4.4
func (g *Script) ConfigOptions() []Option
func (*Script) Description ¶ added in v1.4.4
func (*Script) RawTransform ¶ added in v1.4.4
func (*Script) SampleConfig ¶ added in v1.4.4
type Spliter ¶ added in v1.3.3
type Spliter struct { Key string `json:"key"` SeparateKey string `json:"sep"` ArrayName string `json:"newfield"` ArrayNameNew string `json:"new"` // contains filtered or unexported fields }
func (*Spliter) ConfigOptions ¶ added in v1.3.3
func (g *Spliter) ConfigOptions() []Option
func (*Spliter) Description ¶ added in v1.3.3
func (*Spliter) RawTransform ¶ added in v1.3.3
func (*Spliter) SampleConfig ¶ added in v1.3.3
type Sub ¶ added in v1.5.4
type Sub struct { Key string `json:"key"` New string `json:"new"` Start int `json:"start"` End int `json:"end"` CStage string `json:"stage"` // contains filtered or unexported fields }
func (*Sub) ConfigOptions ¶ added in v1.5.4
func (s *Sub) ConfigOptions() []Option
func (*Sub) Description ¶ added in v1.5.4
func (*Sub) RawTransform ¶ added in v1.5.4
func (*Sub) SampleConfig ¶ added in v1.5.4
type Timestamp ¶ added in v1.5.4
type Timestamp struct { Key string `json:"key"` New string `json:"new"` LayoutBefore string `json:"time_layout_before"` Offset int `json:"offset"` Precision string `json:"precision"` Override bool `json:"override"` // contains filtered or unexported fields }
func (*Timestamp) ConfigOptions ¶ added in v1.5.4
func (t *Timestamp) ConfigOptions() []Option
func (*Timestamp) Description ¶ added in v1.5.4
func (*Timestamp) RawTransform ¶ added in v1.5.4
func (*Timestamp) SampleConfig ¶ added in v1.5.4
type Trim ¶ added in v1.4.8
type Trim struct { Key string `json:"key"` Characters string `json:"characters"` Place string `json:"place"` // contains filtered or unexported fields }
func (*Trim) ConfigOptions ¶ added in v1.4.8
func (g *Trim) ConfigOptions() []Option
func (*Trim) Description ¶ added in v1.4.8
func (*Trim) RawTransform ¶ added in v1.4.8
func (*Trim) SampleConfig ¶ added in v1.4.8
type URLConvert ¶ added in v1.5.4
type URLConvert struct { Mode string `json:"mode"` Key string `json:"key"` CStage string `json:"stage"` // contains filtered or unexported fields }
func (*URLConvert) ConfigOptions ¶ added in v1.5.4
func (u *URLConvert) ConfigOptions() []Option
func (*URLConvert) Description ¶ added in v1.5.4
func (u *URLConvert) Description() string
func (*URLConvert) Init ¶ added in v1.5.4
func (u *URLConvert) Init() error
func (*URLConvert) RawTransform ¶ added in v1.5.4
func (u *URLConvert) RawTransform(datas []string) ([]string, error)
func (*URLConvert) SampleConfig ¶ added in v1.5.4
func (u *URLConvert) SampleConfig() string
func (*URLConvert) SetStats ¶ added in v1.5.4
func (u *URLConvert) SetStats(err string) StatsInfo
func (*URLConvert) Stage ¶ added in v1.5.4
func (u *URLConvert) Stage() string
func (*URLConvert) Stats ¶ added in v1.5.4
func (u *URLConvert) Stats() StatsInfo
func (*URLConvert) Transform ¶ added in v1.5.4
func (u *URLConvert) Transform(datas []Data) ([]Data, error)
func (*URLConvert) Type ¶ added in v1.5.4
func (u *URLConvert) Type() string
type UrlParam ¶ added in v1.3.6
type UrlParam struct { Key string `json:"key"` SelectKeys string `json:"select_keys"` // contains filtered or unexported fields }
func (*UrlParam) ConfigOptions ¶ added in v1.3.6
func (p *UrlParam) ConfigOptions() []Option
func (*UrlParam) Description ¶ added in v1.3.6
func (*UrlParam) RawTransform ¶ added in v1.3.6
func (*UrlParam) SampleConfig ¶ added in v1.3.6
type Xml ¶ added in v1.4.6
type Xml struct { Key string `json:"key"` New string `json:"new"` Keep bool `json:"keep"` Expand bool `json:"expand"` DiscardKey bool `json:"discard_key"` NoAttr bool `json:"no_attr"` // contains filtered or unexported fields }
func (*Xml) ConfigOptions ¶ added in v1.4.6
func (g *Xml) ConfigOptions() []Option
func (*Xml) Description ¶ added in v1.4.6
func (*Xml) RawTransform ¶ added in v1.4.6
func (*Xml) SampleConfig ¶ added in v1.4.6
Click to show internal directories.
Click to hide internal directories.