chore(deps): Bump golangci-lint from v1.61.0 to v1.62.0 (#16172)
This commit is contained in:
parent
e55c25e278
commit
70e1cbc0be
|
|
@ -106,7 +106,7 @@ jobs:
|
||||||
- run: 'make check-deps'
|
- run: 'make check-deps'
|
||||||
- run:
|
- run:
|
||||||
name: "Install golangci-lint"
|
name: "Install golangci-lint"
|
||||||
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.61.0
|
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.62.0
|
||||||
- run:
|
- run:
|
||||||
name: "golangci-lint/Linux"
|
name: "golangci-lint/Linux"
|
||||||
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
||||||
|
|
@ -120,7 +120,7 @@ jobs:
|
||||||
- check-changed-files-or-halt
|
- check-changed-files-or-halt
|
||||||
- run:
|
- run:
|
||||||
name: "Install golangci-lint"
|
name: "Install golangci-lint"
|
||||||
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.61.0
|
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.62.0
|
||||||
- run:
|
- run:
|
||||||
name: "golangci-lint/macOS"
|
name: "golangci-lint/macOS"
|
||||||
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
||||||
|
|
@ -134,7 +134,7 @@ jobs:
|
||||||
- check-changed-files-or-halt
|
- check-changed-files-or-halt
|
||||||
- run:
|
- run:
|
||||||
name: "Install golangci-lint"
|
name: "Install golangci-lint"
|
||||||
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.61.0
|
command: go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.62.0
|
||||||
- run:
|
- run:
|
||||||
name: "golangci-lint/Windows"
|
name: "golangci-lint/Windows"
|
||||||
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
# There are only 4 vCPUs available for this executor, so use only 4 instead of the default number
|
||||||
|
|
|
||||||
|
|
@ -100,8 +100,8 @@ linters-settings:
|
||||||
- codegenComment
|
- codegenComment
|
||||||
- commentedOutCode
|
- commentedOutCode
|
||||||
- deferInLoop
|
- deferInLoop
|
||||||
- dupArg
|
|
||||||
- deprecatedComment
|
- deprecatedComment
|
||||||
|
- dupArg
|
||||||
- dupBranchBody
|
- dupBranchBody
|
||||||
- dupCase
|
- dupCase
|
||||||
- dupSubExpr
|
- dupSubExpr
|
||||||
|
|
@ -130,8 +130,8 @@ linters-settings:
|
||||||
# performance
|
# performance
|
||||||
- appendCombine
|
- appendCombine
|
||||||
- equalFold
|
- equalFold
|
||||||
- indexAlloc
|
|
||||||
- hugeParam
|
- hugeParam
|
||||||
|
- indexAlloc
|
||||||
- preferDecodeRune
|
- preferDecodeRune
|
||||||
- preferFprint
|
- preferFprint
|
||||||
- preferStringWriter
|
- preferStringWriter
|
||||||
|
|
@ -280,9 +280,10 @@ linters-settings:
|
||||||
- name: import-shadowing
|
- name: import-shadowing
|
||||||
- name: increment-decrement
|
- name: increment-decrement
|
||||||
- name: indent-error-flow
|
- name: indent-error-flow
|
||||||
- name: max-public-structs
|
# Enable again when https://github.com/mgechev/revive/issues/1103 is fixed
|
||||||
exclude: [ "TEST" ]
|
# - name: max-public-structs
|
||||||
arguments: [ 5 ]
|
# exclude: [ "TEST" ]
|
||||||
|
# arguments: [ 5 ]
|
||||||
- name: modifies-parameter
|
- name: modifies-parameter
|
||||||
- name: modifies-value-receiver
|
- name: modifies-value-receiver
|
||||||
- name: optimize-operands-order
|
- name: optimize-operands-order
|
||||||
|
|
@ -295,16 +296,10 @@ linters-settings:
|
||||||
- name: redundant-import-alias
|
- name: redundant-import-alias
|
||||||
- name: string-format
|
- name: string-format
|
||||||
arguments:
|
arguments:
|
||||||
- - 'fmt.Errorf[0]'
|
- - 'fmt.Errorf[0],errors.New[0]'
|
||||||
- '/^([^A-Z]|$)/'
|
- '/^([^A-Z]|$)/'
|
||||||
- 'Error string must not start with a capital letter.'
|
- 'Error string must not start with a capital letter.'
|
||||||
- - 'fmt.Errorf[0]'
|
- - 'fmt.Errorf[0],errors.New[0]'
|
||||||
- '/(^|[^\.!?])$/'
|
|
||||||
- 'Error string must not end in punctuation.'
|
|
||||||
- - 'errors.New[0]'
|
|
||||||
- '/^([^A-Z]|$)/'
|
|
||||||
- 'Error string must not start with a capital letter.'
|
|
||||||
- - 'errors.New[0]'
|
|
||||||
- '/(^|[^\.!?])$/'
|
- '/(^|[^\.!?])$/'
|
||||||
- 'Error string must not end in punctuation.'
|
- 'Error string must not end in punctuation.'
|
||||||
- - 'panic'
|
- - 'panic'
|
||||||
|
|
@ -354,11 +349,6 @@ linters-settings:
|
||||||
- suite-thelper
|
- suite-thelper
|
||||||
- useless-assert
|
- useless-assert
|
||||||
|
|
||||||
run:
|
|
||||||
# Timeout for analysis, e.g. 30s, 5m.
|
|
||||||
# Default: 1m
|
|
||||||
timeout: 10m
|
|
||||||
|
|
||||||
issues:
|
issues:
|
||||||
# List of regexps of issue texts to exclude.
|
# List of regexps of issue texts to exclude.
|
||||||
#
|
#
|
||||||
|
|
@ -478,3 +468,8 @@ output:
|
||||||
# Show statistics per linter.
|
# Show statistics per linter.
|
||||||
# Default: false
|
# Default: false
|
||||||
show-stats: true
|
show-stats: true
|
||||||
|
|
||||||
|
run:
|
||||||
|
# Timeout for analysis, e.g. 30s, 5m.
|
||||||
|
# Default: 1m
|
||||||
|
timeout: 10m
|
||||||
|
|
|
||||||
2
Makefile
2
Makefile
|
|
@ -180,7 +180,7 @@ vet:
|
||||||
.PHONY: lint-install
|
.PHONY: lint-install
|
||||||
lint-install:
|
lint-install:
|
||||||
@echo "Installing golangci-lint"
|
@echo "Installing golangci-lint"
|
||||||
go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.61.0
|
go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.62.0
|
||||||
|
|
||||||
@echo "Installing markdownlint"
|
@echo "Installing markdownlint"
|
||||||
npm install -g markdownlint-cli
|
npm install -g markdownlint-cli
|
||||||
|
|
|
||||||
|
|
@ -59,7 +59,7 @@ func TestReadBinaryFile(t *testing.T) {
|
||||||
cmd.Stderr = &errb
|
cmd.Stderr = &errb
|
||||||
err = cmd.Run()
|
err = cmd.Run()
|
||||||
|
|
||||||
require.NoError(t, err, fmt.Sprintf("stdout: %s, stderr: %s", outb.String(), errb.String()))
|
require.NoErrorf(t, err, "stdout: %s, stderr: %s", outb.String(), errb.String())
|
||||||
c := config.NewConfig()
|
c := config.NewConfig()
|
||||||
err = c.LoadConfig(binaryFile)
|
err = c.LoadConfig(binaryFile)
|
||||||
require.Error(t, err)
|
require.Error(t, err)
|
||||||
|
|
|
||||||
|
|
@ -1,15 +1,15 @@
|
||||||
package parallel_test
|
package parallel_test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
|
||||||
"github.com/influxdata/telegraf"
|
"github.com/influxdata/telegraf"
|
||||||
"github.com/influxdata/telegraf/metric"
|
"github.com/influxdata/telegraf/metric"
|
||||||
"github.com/influxdata/telegraf/plugins/common/parallel"
|
"github.com/influxdata/telegraf/plugins/common/parallel"
|
||||||
"github.com/influxdata/telegraf/testutil"
|
"github.com/influxdata/telegraf/testutil"
|
||||||
"github.com/stretchr/testify/require"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestOrderedJobsStayOrdered(t *testing.T) {
|
func TestOrderedJobsStayOrdered(t *testing.T) {
|
||||||
|
|
@ -31,7 +31,7 @@ func TestOrderedJobsStayOrdered(t *testing.T) {
|
||||||
p.Stop()
|
p.Stop()
|
||||||
|
|
||||||
i := 0
|
i := 0
|
||||||
require.Len(t, acc.Metrics, 20000, fmt.Sprintf("expected 20k metrics but got %d", len(acc.GetTelegrafMetrics())))
|
require.Len(t, acc.Metrics, 20000)
|
||||||
for _, m := range acc.GetTelegrafMetrics() {
|
for _, m := range acc.GetTelegrafMetrics() {
|
||||||
v, ok := m.GetField("val")
|
v, ok := m.GetField("val")
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
@ -63,7 +63,7 @@ func TestUnorderedJobsDontDropAnyJobs(t *testing.T) {
|
||||||
p.Stop()
|
p.Stop()
|
||||||
|
|
||||||
actualTotal := int64(0)
|
actualTotal := int64(0)
|
||||||
require.Len(t, acc.Metrics, 20000, fmt.Sprintf("expected 20k metrics but got %d", len(acc.GetTelegrafMetrics())))
|
require.Len(t, acc.Metrics, 20000)
|
||||||
for _, m := range acc.GetTelegrafMetrics() {
|
for _, m := range acc.GetTelegrafMetrics() {
|
||||||
v, ok := m.GetField("val")
|
v, ok := m.GetField("val")
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
|
||||||
|
|
@ -429,7 +429,7 @@ func TestGather(t *testing.T) {
|
||||||
t.Run(tt.name, func(t *testing.T) {
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
var acc testutil.Accumulator
|
var acc testutil.Accumulator
|
||||||
plugin.Metrics[0].MetricNames = tt.metricNames
|
plugin.Metrics[0].MetricNames = tt.metricNames
|
||||||
require.Empty(t, acc.GatherError(plugin.Gather))
|
require.NoError(t, acc.GatherError(plugin.Gather))
|
||||||
require.Equal(t, acc.HasMeasurement("aliyuncms_acs_slb_dashboard"), tt.hasMeasurement)
|
require.Equal(t, acc.HasMeasurement("aliyuncms_acs_slb_dashboard"), tt.hasMeasurement)
|
||||||
if tt.hasMeasurement {
|
if tt.hasMeasurement {
|
||||||
acc.AssertContainsTaggedFields(t, "aliyuncms_acs_slb_dashboard", tt.expected[0].Fields(), tt.expected[0].Tags())
|
acc.AssertContainsTaggedFields(t, "aliyuncms_acs_slb_dashboard", tt.expected[0].Fields(), tt.expected[0].Tags())
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,6 @@ package dcos
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
|
|
@ -200,7 +199,7 @@ func TestAddNodeMetrics(t *testing.T) {
|
||||||
dcos := &DCOS{}
|
dcos := &DCOS{}
|
||||||
dcos.addNodeMetrics(&acc, "a", tt.metrics)
|
dcos.addNodeMetrics(&acc, "a", tt.metrics)
|
||||||
for i, ok := range tt.check(&acc) {
|
for i, ok := range tt.check(&acc) {
|
||||||
require.True(t, ok, fmt.Sprintf("Index was not true: %d", i))
|
require.Truef(t, ok, "Index was not true: %d", i)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
@ -271,7 +270,7 @@ func TestAddContainerMetrics(t *testing.T) {
|
||||||
dcos := &DCOS{}
|
dcos := &DCOS{}
|
||||||
dcos.addContainerMetrics(&acc, "a", tt.metrics)
|
dcos.addContainerMetrics(&acc, "a", tt.metrics)
|
||||||
for i, ok := range tt.check(&acc) {
|
for i, ok := range tt.check(&acc) {
|
||||||
require.True(t, ok, fmt.Sprintf("Index was not true: %d", i))
|
require.Truef(t, ok, "Index was not true: %d", i)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
@ -345,7 +344,7 @@ func TestAddAppMetrics(t *testing.T) {
|
||||||
dcos := &DCOS{}
|
dcos := &DCOS{}
|
||||||
dcos.addAppMetrics(&acc, "a", tt.metrics)
|
dcos.addAppMetrics(&acc, "a", tt.metrics)
|
||||||
for i, ok := range tt.check(&acc) {
|
for i, ok := range tt.check(&acc) {
|
||||||
require.True(t, ok, fmt.Sprintf("Index was not true: %d", i))
|
require.Truef(t, ok, "Index was not true: %d", i)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
@ -433,7 +432,7 @@ func TestGatherFilterNode(t *testing.T) {
|
||||||
err := dcos.Gather(&acc)
|
err := dcos.Gather(&acc)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
for i, ok := range tt.check(&acc) {
|
for i, ok := range tt.check(&acc) {
|
||||||
require.True(t, ok, fmt.Sprintf("Index was not true: %d", i))
|
require.Truef(t, ok, "Index was not true: %d", i)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -62,8 +62,8 @@ func TestSplitCSVLineIntoValues(t *testing.T) {
|
||||||
splitCSV, err = splitCSVLineIntoValues(wrongLine)
|
splitCSV, err = splitCSVLineIntoValues(wrongLine)
|
||||||
require.Error(t, err)
|
require.Error(t, err)
|
||||||
require.Equal(t, "", splitCSV.timeValue)
|
require.Equal(t, "", splitCSV.timeValue)
|
||||||
require.Nil(t, nil, splitCSV.metricsValues)
|
require.Nil(t, splitCSV.metricsValues)
|
||||||
require.Nil(t, nil, splitCSV.coreOrPIDsValues)
|
require.Nil(t, splitCSV.coreOrPIDsValues)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestFindPIDsInMeasurement(t *testing.T) {
|
func TestFindPIDsInMeasurement(t *testing.T) {
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package internal
|
package internal
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
|
|
@ -108,7 +107,7 @@ func TestGostats(t *testing.T) {
|
||||||
switch value.(type) {
|
switch value.(type) {
|
||||||
case int64, uint64, float64:
|
case int64, uint64, float64:
|
||||||
default:
|
default:
|
||||||
require.True(t, false, fmt.Sprintf("field %s is of non-numeric type %T\n", name, value))
|
require.Truef(t, false, "field %s is of non-numeric type %T\n", name, value)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -218,22 +218,22 @@ func TestPostgresqlFieldOutputIntegration(t *testing.T) {
|
||||||
|
|
||||||
for _, field := range intMetrics {
|
for _, field := range intMetrics {
|
||||||
_, found := acc.Int64Field(measurement, field)
|
_, found := acc.Int64Field(measurement, field)
|
||||||
require.True(t, found, fmt.Sprintf("expected %s to be an integer", field))
|
require.Truef(t, found, "expected %s to be an integer", field)
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, field := range int32Metrics {
|
for _, field := range int32Metrics {
|
||||||
_, found := acc.Int32Field(measurement, field)
|
_, found := acc.Int32Field(measurement, field)
|
||||||
require.True(t, found, fmt.Sprintf("expected %s to be an int32", field))
|
require.Truef(t, found, "expected %s to be an int32", field)
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, field := range floatMetrics {
|
for _, field := range floatMetrics {
|
||||||
_, found := acc.FloatField(measurement, field)
|
_, found := acc.FloatField(measurement, field)
|
||||||
require.True(t, found, fmt.Sprintf("expected %s to be a float64", field))
|
require.Truef(t, found, "expected %s to be a float64", field)
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, field := range stringMetrics {
|
for _, field := range stringMetrics {
|
||||||
_, found := acc.StringField(measurement, field)
|
_, found := acc.StringField(measurement, field)
|
||||||
require.True(t, found, fmt.Sprintf("expected %s to be a str", field))
|
require.Truef(t, found, "expected %s to be a str", field)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,6 @@ package vsphere
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"fmt"
|
|
||||||
"net/url"
|
"net/url"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
@ -518,7 +517,7 @@ func testCollection(t *testing.T, excludeClusters bool) {
|
||||||
require.NoError(t, v.Start(&acc))
|
require.NoError(t, v.Start(&acc))
|
||||||
defer v.Stop()
|
defer v.Stop()
|
||||||
require.NoError(t, v.Gather(&acc))
|
require.NoError(t, v.Gather(&acc))
|
||||||
require.Empty(t, acc.Errors, fmt.Sprintf("Errors found: %s", acc.Errors))
|
require.Emptyf(t, acc.Errors, "Errors found: %s", acc.Errors)
|
||||||
require.NotEmpty(t, acc.Metrics, "No metrics were collected")
|
require.NotEmpty(t, acc.Metrics, "No metrics were collected")
|
||||||
cache := make(map[string]string)
|
cache := make(map[string]string)
|
||||||
client, err := v.endpoints[0].clientFactory.GetClient(context.Background())
|
client, err := v.endpoints[0].clientFactory.GetClient(context.Background())
|
||||||
|
|
@ -621,6 +620,6 @@ func TestVersionLowerThan(t *testing.T) {
|
||||||
}
|
}
|
||||||
for _, tc := range tests {
|
for _, tc := range tests {
|
||||||
result := versionLowerThan(tc.current, tc.major, tc.minor)
|
result := versionLowerThan(tc.current, tc.major, tc.minor)
|
||||||
require.Equal(t, tc.result, result, fmt.Sprintf("%s < %d.%d", tc.current, tc.major, tc.minor))
|
require.Equalf(t, tc.result, result, "%s < %d.%d", tc.current, tc.major, tc.minor)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ package win_perf_counters
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
@ -171,14 +170,10 @@ func TestWinPerfCountersConfigGet2Integration(t *testing.T) {
|
||||||
hostCounters, ok := m.hostCounters["localhost"]
|
hostCounters, ok := m.hostCounters["localhost"]
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
||||||
if len(hostCounters.counters) == 1 {
|
if len(hostCounters.counters) == 0 {
|
||||||
require.NoError(t, nil)
|
require.FailNow(t, "no results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
} else if len(hostCounters.counters) == 0 {
|
|
||||||
err2 := fmt.Errorf("no results returned from the counterPath: %v", len(hostCounters.counters))
|
|
||||||
require.NoError(t, err2)
|
|
||||||
} else if len(hostCounters.counters) > 1 {
|
} else if len(hostCounters.counters) > 1 {
|
||||||
err2 := fmt.Errorf("too many results returned from the counterPath: %v", len(hostCounters.counters))
|
require.FailNow(t, "too many results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
require.NoError(t, err2)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -214,14 +209,10 @@ func TestWinPerfCountersConfigGet3Integration(t *testing.T) {
|
||||||
hostCounters, ok := m.hostCounters["localhost"]
|
hostCounters, ok := m.hostCounters["localhost"]
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
||||||
if len(hostCounters.counters) == 2 {
|
if len(hostCounters.counters) < 2 {
|
||||||
require.NoError(t, nil)
|
require.FailNow(t, "too few results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
} else if len(hostCounters.counters) < 2 {
|
|
||||||
err2 := fmt.Errorf("too few results returned from the counterPath: %v", len(hostCounters.counters))
|
|
||||||
require.NoError(t, err2)
|
|
||||||
} else if len(hostCounters.counters) > 2 {
|
} else if len(hostCounters.counters) > 2 {
|
||||||
err2 := fmt.Errorf("too many results returned from the counterPath: %v", len(hostCounters.counters))
|
require.FailNow(t, "too many results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
require.NoError(t, err2)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -255,14 +246,10 @@ func TestWinPerfCountersConfigGet4Integration(t *testing.T) {
|
||||||
hostCounters, ok := m.hostCounters["localhost"]
|
hostCounters, ok := m.hostCounters["localhost"]
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
||||||
if len(hostCounters.counters) == 2 {
|
if len(hostCounters.counters) < 2 {
|
||||||
require.NoError(t, nil)
|
require.FailNow(t, "too few results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
} else if len(hostCounters.counters) < 2 {
|
|
||||||
err2 := fmt.Errorf("too few results returned from the counterPath: %v", len(hostCounters.counters))
|
|
||||||
require.NoError(t, err2)
|
|
||||||
} else if len(hostCounters.counters) > 2 {
|
} else if len(hostCounters.counters) > 2 {
|
||||||
err2 := fmt.Errorf("too many results returned from the counterPath: %v", len(hostCounters.counters))
|
require.FailNow(t, "too many results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
require.NoError(t, err2)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -296,14 +283,10 @@ func TestWinPerfCountersConfigGet5Integration(t *testing.T) {
|
||||||
hostCounters, ok := m.hostCounters["localhost"]
|
hostCounters, ok := m.hostCounters["localhost"]
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
||||||
if len(hostCounters.counters) == 4 {
|
if len(hostCounters.counters) < 4 {
|
||||||
require.NoError(t, nil)
|
require.FailNow(t, "too few results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
} else if len(hostCounters.counters) < 4 {
|
|
||||||
err2 := fmt.Errorf("too few results returned from the counterPath: %v", len(hostCounters.counters))
|
|
||||||
require.NoError(t, err2)
|
|
||||||
} else if len(hostCounters.counters) > 4 {
|
} else if len(hostCounters.counters) > 4 {
|
||||||
err2 := fmt.Errorf("too many results returned from the counterPath: %v", len(hostCounters.counters))
|
require.FailNow(t, "too many results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
require.NoError(t, err2)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -365,14 +348,10 @@ func TestWinPerfCountersConfigGet7Integration(t *testing.T) {
|
||||||
hostCounters, ok := m.hostCounters["localhost"]
|
hostCounters, ok := m.hostCounters["localhost"]
|
||||||
require.True(t, ok)
|
require.True(t, ok)
|
||||||
|
|
||||||
if len(hostCounters.counters) == 2 {
|
if len(hostCounters.counters) < 2 {
|
||||||
require.NoError(t, nil)
|
require.FailNow(t, "too few results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
} else if len(hostCounters.counters) < 2 {
|
|
||||||
err2 := fmt.Errorf("too few results returned from the counterPath: %v", len(hostCounters.counters))
|
|
||||||
require.NoError(t, err2)
|
|
||||||
} else if len(hostCounters.counters) > 2 {
|
} else if len(hostCounters.counters) > 2 {
|
||||||
err2 := fmt.Errorf("too many results returned from the counterPath: %v", len(hostCounters.counters))
|
require.FailNow(t, "too many results returned from the counterPath: %v", len(hostCounters.counters))
|
||||||
require.NoError(t, err2)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package cloudwatch
|
package cloudwatch
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"math"
|
"math"
|
||||||
"sort"
|
"sort"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
@ -68,11 +67,11 @@ func TestBuildMetricDatums(t *testing.T) {
|
||||||
}
|
}
|
||||||
for _, point := range validMetrics {
|
for _, point := range validMetrics {
|
||||||
datums := BuildMetricDatum(false, false, point)
|
datums := BuildMetricDatum(false, false, point)
|
||||||
require.Len(t, datums, 1, fmt.Sprintf("Valid point should create a Datum {value: %v}", point))
|
require.Lenf(t, datums, 1, "Valid point should create a Datum {value: %v}", point)
|
||||||
}
|
}
|
||||||
for _, point := range invalidMetrics {
|
for _, point := range invalidMetrics {
|
||||||
datums := BuildMetricDatum(false, false, point)
|
datums := BuildMetricDatum(false, false, point)
|
||||||
require.Empty(t, datums, fmt.Sprintf("Valid point should not create a Datum {value: %v}", point))
|
require.Emptyf(t, datums, "Valid point should not create a Datum {value: %v}", point)
|
||||||
}
|
}
|
||||||
|
|
||||||
statisticMetric := metric.New(
|
statisticMetric := metric.New(
|
||||||
|
|
@ -82,7 +81,7 @@ func TestBuildMetricDatums(t *testing.T) {
|
||||||
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
||||||
)
|
)
|
||||||
datums := BuildMetricDatum(true, false, statisticMetric)
|
datums := BuildMetricDatum(true, false, statisticMetric)
|
||||||
require.Len(t, datums, 1, fmt.Sprintf("Valid point should create a Datum {value: %v}", statisticMetric))
|
require.Lenf(t, datums, 1, "Valid point should create a Datum {value: %v}", statisticMetric)
|
||||||
|
|
||||||
multiFieldsMetric := metric.New(
|
multiFieldsMetric := metric.New(
|
||||||
"test1",
|
"test1",
|
||||||
|
|
@ -91,7 +90,7 @@ func TestBuildMetricDatums(t *testing.T) {
|
||||||
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
||||||
)
|
)
|
||||||
datums = BuildMetricDatum(true, false, multiFieldsMetric)
|
datums = BuildMetricDatum(true, false, multiFieldsMetric)
|
||||||
require.Len(t, datums, 4, fmt.Sprintf("Each field should create a Datum {value: %v}", multiFieldsMetric))
|
require.Lenf(t, datums, 4, "Each field should create a Datum {value: %v}", multiFieldsMetric)
|
||||||
|
|
||||||
multiStatisticMetric := metric.New(
|
multiStatisticMetric := metric.New(
|
||||||
"test1",
|
"test1",
|
||||||
|
|
@ -105,7 +104,7 @@ func TestBuildMetricDatums(t *testing.T) {
|
||||||
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC),
|
||||||
)
|
)
|
||||||
datums = BuildMetricDatum(true, false, multiStatisticMetric)
|
datums = BuildMetricDatum(true, false, multiStatisticMetric)
|
||||||
require.Len(t, datums, 7, fmt.Sprintf("Valid point should create a Datum {value: %v}", multiStatisticMetric))
|
require.Lenf(t, datums, 7, "Valid point should create a Datum {value: %v}", multiStatisticMetric)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestMetricDatumResolution(t *testing.T) {
|
func TestMetricDatumResolution(t *testing.T) {
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package dropwizard
|
package dropwizard
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
|
@ -111,7 +110,7 @@ func TestParseValidEmbeddedCounterJSON(t *testing.T) {
|
||||||
"tag2": "yellow",
|
"tag2": "yellow",
|
||||||
"tag3 space,comma=equals": "red ,=",
|
"tag3 space,comma=equals": "red ,=",
|
||||||
}, metrics[0].Tags())
|
}, metrics[0].Tags())
|
||||||
require.True(t, metricTime.Equal(metrics[0].Time()), fmt.Sprintf("%s should be equal to %s", metrics[0].Time(), metricTime))
|
require.Truef(t, metricTime.Equal(metrics[0].Time()), "%s should be equal to %s", metrics[0].Time(), metricTime)
|
||||||
|
|
||||||
// now test json tags through TagPathsMap
|
// now test json tags through TagPathsMap
|
||||||
parser2 := &Parser{
|
parser2 := &Parser{
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"encoding/gob"
|
"encoding/gob"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
@ -3743,7 +3742,7 @@ func parseMetricsFrom(t *testing.T, lines []string, header string) (metrics []te
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
require.NotEqual(t, -1, startIdx, fmt.Sprintf("Header %q must exist in file", header))
|
require.NotEqualf(t, -1, startIdx, "Header %q must exist in file", header)
|
||||||
for i := startIdx; i < len(lines); i++ {
|
for i := startIdx; i < len(lines); i++ {
|
||||||
line := strings.TrimLeft(lines[i], "# ")
|
line := strings.TrimLeft(lines[i], "# ")
|
||||||
if line == "" || line == "'''" {
|
if line == "" || line == "'''" {
|
||||||
|
|
@ -3753,7 +3752,7 @@ func parseMetricsFrom(t *testing.T, lines []string, header string) (metrics []te
|
||||||
}
|
}
|
||||||
for i := startIdx; i < endIdx; i++ {
|
for i := startIdx; i < endIdx; i++ {
|
||||||
m, err := parser.ParseLine(strings.TrimLeft(lines[i], "# "))
|
m, err := parser.ParseLine(strings.TrimLeft(lines[i], "# "))
|
||||||
require.NoError(t, err, fmt.Sprintf("Expected to be able to parse %q metric, but found error", header))
|
require.NoErrorf(t, err, "Expected to be able to parse %q metric, but found error", header)
|
||||||
metrics = append(metrics, m)
|
metrics = append(metrics, m)
|
||||||
}
|
}
|
||||||
return metrics
|
return metrics
|
||||||
|
|
@ -3772,7 +3771,7 @@ func parseErrorMessage(t *testing.T, lines []string, header string) string {
|
||||||
if startIdx == -1 {
|
if startIdx == -1 {
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
require.Less(t, startIdx, len(lines), fmt.Sprintf("Expected to find the error message after %q, but found none", header))
|
require.Lessf(t, startIdx, len(lines), "Expected to find the error message after %q, but found none", header)
|
||||||
return strings.TrimLeft(lines[startIdx], "# ")
|
return strings.TrimLeft(lines[startIdx], "# ")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue