Skip to content

Commit

Permalink
fix: Linter fixes for config/config.go (influxdata#10710)
Browse files Browse the repository at this point in the history
  • Loading branch information
zak-pawel authored Feb 23, 2022
1 parent 066ab25 commit f3904d3
Show file tree
Hide file tree
Showing 2 changed files with 43 additions and 42 deletions.
2 changes: 1 addition & 1 deletion .golangci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ linters-settings:
- name: unconditional-recursion
- name: unexported-naming
- name: unhandled-error
arguments: ["fmt.Printf", "fmt.Println"]
arguments: ["fmt.Printf", "fmt.Println", "fmt.Print"]
- name: unnecessary-stmt
- name: unreachable-code
# - name: unused-parameter
Expand Down
83 changes: 42 additions & 41 deletions config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -456,7 +456,7 @@ func PrintSampleConfig(
processorFilters []string,
) {
// print headers
fmt.Printf(header)
fmt.Print(header)

if len(sectionFilters) == 0 {
sectionFilters = sectionDefaults
Expand All @@ -467,11 +467,11 @@ func PrintSampleConfig(
if sliceContains("outputs", sectionFilters) {
if len(outputFilters) != 0 {
if len(outputFilters) >= 3 && outputFilters[1] != "none" {
fmt.Printf(outputHeader)
fmt.Print(outputHeader)
}
printFilteredOutputs(outputFilters, false)
} else {
fmt.Printf(outputHeader)
fmt.Print(outputHeader)
printFilteredOutputs(outputDefaults, false)
// Print non-default outputs, commented
var pnames []string
Expand All @@ -489,11 +489,11 @@ func PrintSampleConfig(
if sliceContains("processors", sectionFilters) {
if len(processorFilters) != 0 {
if len(processorFilters) >= 3 && processorFilters[1] != "none" {
fmt.Printf(processorHeader)
fmt.Print(processorHeader)
}
printFilteredProcessors(processorFilters, false)
} else {
fmt.Printf(processorHeader)
fmt.Print(processorHeader)
pnames := []string{}
for pname := range processors.Processors {
pnames = append(pnames, pname)
Expand All @@ -507,11 +507,11 @@ func PrintSampleConfig(
if sliceContains("aggregators", sectionFilters) {
if len(aggregatorFilters) != 0 {
if len(aggregatorFilters) >= 3 && aggregatorFilters[1] != "none" {
fmt.Printf(aggregatorHeader)
fmt.Print(aggregatorHeader)
}
printFilteredAggregators(aggregatorFilters, false)
} else {
fmt.Printf(aggregatorHeader)
fmt.Print(aggregatorHeader)
pnames := []string{}
for pname := range aggregators.Aggregators {
pnames = append(pnames, pname)
Expand All @@ -525,11 +525,11 @@ func PrintSampleConfig(
if sliceContains("inputs", sectionFilters) {
if len(inputFilters) != 0 {
if len(inputFilters) >= 3 && inputFilters[1] != "none" {
fmt.Printf(inputHeader)
fmt.Print(inputHeader)
}
printFilteredInputs(inputFilters, false)
} else {
fmt.Printf(inputHeader)
fmt.Print(inputHeader)
printFilteredInputs(inputDefaults, false)
// Print non-default inputs, commented
var pnames []string
Expand Down Expand Up @@ -607,8 +607,7 @@ func printFilteredInputs(inputFilters []string, commented bool) {
creator := inputs.Inputs[pname]
input := creator()

switch p := input.(type) {
case telegraf.ServiceInput:
if p, ok := input.(telegraf.ServiceInput); ok {
servInputs[pname] = p
servInputNames = append(servInputNames, pname)
continue
Expand All @@ -623,7 +622,7 @@ func printFilteredInputs(inputFilters []string, commented bool) {
}
sort.Strings(servInputNames)

fmt.Printf(serviceInputHeader)
fmt.Print(serviceInputHeader)
for _, name := range servInputNames {
printConfig(name, servInputs[name], "inputs", commented, inputs.Deprecations[name])
}
Expand All @@ -649,11 +648,11 @@ func printFilteredOutputs(outputFilters []string, commented bool) {

func printFilteredGlobalSections(sectionFilters []string) {
if sliceContains("global_tags", sectionFilters) {
fmt.Printf(globalTagsConfig)
fmt.Print(globalTagsConfig)
}

if sliceContains("agent", sectionFilters) {
fmt.Printf(agentConfig)
fmt.Print(agentConfig)
}
}

Expand Down Expand Up @@ -698,21 +697,23 @@ func sliceContains(name string, list []string) bool {

// PrintInputConfig prints the config usage of a single input.
func PrintInputConfig(name string) error {
if creator, ok := inputs.Inputs[name]; ok {
printConfig(name, creator(), "inputs", false, inputs.Deprecations[name])
} else {
return fmt.Errorf("Input %s not found", name)
creator, ok := inputs.Inputs[name]
if !ok {
return fmt.Errorf("input %s not found", name)
}

printConfig(name, creator(), "inputs", false, inputs.Deprecations[name])
return nil
}

// PrintOutputConfig prints the config usage of a single output.
func PrintOutputConfig(name string) error {
if creator, ok := outputs.Outputs[name]; ok {
printConfig(name, creator(), "outputs", false, outputs.Deprecations[name])
} else {
return fmt.Errorf("Output %s not found", name)
creator, ok := outputs.Outputs[name]
if !ok {
return fmt.Errorf("output %s not found", name)
}

printConfig(name, creator(), "outputs", false, outputs.Deprecations[name])
return nil
}

Expand Down Expand Up @@ -1192,14 +1193,13 @@ func (c *Config) addOutput(name string, table *ast.Table) error {
printHistoricPluginDeprecationNotice("outputs", name, di)
return fmt.Errorf("plugin deprecated")
}
return fmt.Errorf("Undefined but requested output: %s", name)
return fmt.Errorf("undefined but requested output: %s", name)
}
output := creator()

// If the output has a SetSerializer function, then this means it can write
// arbitrary types of output, so build the serializer and set it.
switch t := output.(type) {
case serializers.SerializerOutput:
if t, ok := output.(serializers.SerializerOutput); ok {
serializer, err := c.buildSerializer(table)
if err != nil {
return err
Expand Down Expand Up @@ -1943,16 +1943,16 @@ func (c *Config) getFieldInt64(tbl *ast.Table, fieldName string, target *int64)
func (c *Config) getFieldStringSlice(tbl *ast.Table, fieldName string, target *[]string) {
if node, ok := tbl.Fields[fieldName]; ok {
if kv, ok := node.(*ast.KeyValue); ok {
if ary, ok := kv.Value.(*ast.Array); ok {
for _, elem := range ary.Value {
if str, ok := elem.(*ast.String); ok {
*target = append(*target, str.Value)
}
}
} else {
ary, ok := kv.Value.(*ast.Array)
if !ok {
c.addError(tbl, fmt.Errorf("found unexpected format while parsing %q, expecting string array/slice format", fieldName))
return
}
for _, elem := range ary.Value {
if str, ok := elem.(*ast.String); ok {
*target = append(*target, str.Value)
}
}
}
}
}
Expand All @@ -1962,18 +1962,19 @@ func (c *Config) getFieldTagFilter(tbl *ast.Table, fieldName string, target *[]m
if subtbl, ok := node.(*ast.Table); ok {
for name, val := range subtbl.Fields {
if kv, ok := val.(*ast.KeyValue); ok {
tagfilter := models.TagFilter{Name: name}
if ary, ok := kv.Value.(*ast.Array); ok {
for _, elem := range ary.Value {
if str, ok := elem.(*ast.String); ok {
tagfilter.Filter = append(tagfilter.Filter, str.Value)
}
}
} else {
ary, ok := kv.Value.(*ast.Array)
if !ok {
c.addError(tbl, fmt.Errorf("found unexpected format while parsing %q, expecting string array/slice format on each entry", fieldName))
return
}
*target = append(*target, tagfilter)

tagFilter := models.TagFilter{Name: name}
for _, elem := range ary.Value {
if str, ok := elem.(*ast.String); ok {
tagFilter.Filter = append(tagFilter.Filter, str.Value)
}
}
*target = append(*target, tagFilter)
}
}
}
Expand Down

0 comments on commit f3904d3

Please sign in to comment.