Skip to content

Commit

Permalink
fix k8stag key
Browse files Browse the repository at this point in the history
  • Loading branch information
wonderflow committed Aug 16, 2018
1 parent 9cda102 commit 973e994
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 6 deletions.
12 changes: 8 additions & 4 deletions transforms/mutate/split.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,11 @@ var (
)

type Spliter struct {
Key string `json:"key"`
SeperateKey string `json:"sep"`
ArraryName string `json:"newfield"`
stats StatsInfo
Key string `json:"key"`
SeperateKey string `json:"sep"`
ArraryName string `json:"newfield"`
ArraryNameNew string `json:"new"`
stats StatsInfo
}

func (g *Spliter) RawTransform(datas []string) ([]string, error) {
Expand All @@ -28,6 +29,9 @@ func (g *Spliter) RawTransform(datas []string) ([]string, error) {
func (g *Spliter) Transform(datas []Data) ([]Data, error) {
var err, fmtErr error
errNum := 0
if g.ArraryName == "" {
g.ArraryName = g.ArraryNameNew
}
if g.ArraryName == "" {
fmtErr = errors.New("array name is empty string,can't use as array field key name")
g.stats.LastError = fmtErr.Error()
Expand Down
4 changes: 2 additions & 2 deletions transforms/service/k8stag.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,13 +85,13 @@ func (g *K8sTag) SampleConfig() string {
func (g *K8sTag) ConfigOptions() []Option {
return []Option{
{
KeyName: "key",
KeyName: "sourcefilefield",
ChooseOnly: false,
Default: "",
Required: true,
Placeholder: "my_field_keyname",
DefaultNoUse: true,
Description: "要进行Transform变化的键(key)",
Description: "要进行Transform变化的键(sourcefilefield)",
Type: transforms.TransformTypeString,
ToolTip: "此处填写 File Reader 中 datasource_tag 选项配置的 key,该选项会记录文件路径",
},
Expand Down

0 comments on commit 973e994

Please sign in to comment.