Skip to content

Commit

Permalink
chore(linters): Fix findings found by testifylint: compares (#14177)
Browse files Browse the repository at this point in the history
(cherry picked from commit 7c5b3ea)
  • Loading branch information
zak-pawel authored and powersj committed Nov 13, 2023
1 parent 887fc92 commit 1ac26be
Show file tree
Hide file tree
Showing 11 changed files with 33 additions and 33 deletions.
14 changes: 7 additions & 7 deletions agent/tick_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,8 +74,8 @@ func TestAlignedTickerJitter(t *testing.T) {
case tm := <-ticker.Elapsed():
dur := tm.Sub(last)
// 10s interval + 5s jitter + up to 1s late firing.
require.True(t, dur <= 16*time.Second, "expected elapsed time to be less than 16 seconds, but was %s", dur)
require.True(t, dur >= 5*time.Second, "expected elapsed time to be more than 5 seconds, but was %s", dur)
require.LessOrEqual(t, dur, 16*time.Second, "expected elapsed time to be less than 16 seconds, but was %s", dur)
require.GreaterOrEqual(t, dur, 5*time.Second, "expected elapsed time to be more than 5 seconds, but was %s", dur)
last = last.Add(interval)
default:
}
Expand Down Expand Up @@ -252,7 +252,7 @@ func TestAlignedTickerDistribution(t *testing.T) {
defer ticker.Stop()
dist := simulatedDist(ticker, clk)
printDist(dist)
require.True(t, 350 < dist.Count)
require.Less(t, 350, dist.Count)
require.True(t, 9 < dist.Mean() && dist.Mean() < 11)
}

Expand All @@ -278,7 +278,7 @@ func TestAlignedTickerDistributionWithOffset(t *testing.T) {
defer ticker.Stop()
dist := simulatedDist(ticker, clk)
printDist(dist)
require.True(t, 350 < dist.Count)
require.Less(t, 350, dist.Count)
require.True(t, 9 < dist.Mean() && dist.Mean() < 11)
}

Expand All @@ -304,7 +304,7 @@ func TestUnalignedTickerDistribution(t *testing.T) {
defer ticker.Stop()
dist := simulatedDist(ticker, clk)
printDist(dist)
require.True(t, 350 < dist.Count)
require.Less(t, 350, dist.Count)
require.True(t, 9 < dist.Mean() && dist.Mean() < 11)
}

Expand All @@ -328,7 +328,7 @@ func TestUnalignedTickerDistributionWithOffset(t *testing.T) {
defer ticker.Stop()
dist := simulatedDist(ticker, clk)
printDist(dist)
require.True(t, 350 < dist.Count)
require.Less(t, 350, dist.Count)
require.True(t, 9 < dist.Mean() && dist.Mean() < 11)
}

Expand All @@ -352,7 +352,7 @@ func TestRollingTickerDistribution(t *testing.T) {
defer ticker.Stop()
dist := simulatedDist(ticker, clk)
printDist(dist)
require.True(t, 275 < dist.Count)
require.Less(t, 275, dist.Count)
require.True(t, 12 < dist.Mean() && 13 > dist.Mean())
}

Expand Down
12 changes: 6 additions & 6 deletions internal/internal_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ func TestRunTimeout(t *testing.T) {

require.Equal(t, ErrTimeout, err)
// Verify that command gets killed in 20ms, with some breathing room
require.True(t, elapsed < time.Millisecond*75)
require.Less(t, elapsed, time.Millisecond*75)
}

// Verifies behavior of a command that doesn't get killed.
Expand All @@ -83,7 +83,7 @@ func TestRunTimeoutFastExit(t *testing.T) {

require.NoError(t, err)
// Verify that command gets killed in 20ms, with some breathing room
require.True(t, elapsed < time.Millisecond*75)
require.Less(t, elapsed, time.Millisecond*75)

// Verify "process already finished" log doesn't occur.
time.Sleep(time.Millisecond * 75)
Expand All @@ -103,7 +103,7 @@ func TestCombinedOutputTimeout(t *testing.T) {

require.Equal(t, ErrTimeout, err)
// Verify that command gets killed in 20ms, with some breathing room
require.True(t, elapsed < time.Millisecond*75)
require.Less(t, elapsed, time.Millisecond*75)
}

func TestCombinedOutput(t *testing.T) {
Expand Down Expand Up @@ -151,13 +151,13 @@ func TestRandomSleep(t *testing.T) {
s := time.Now()
RandomSleep(time.Duration(0), make(chan struct{}))
elapsed := time.Since(s)
require.True(t, elapsed < time.Millisecond)
require.Less(t, elapsed, time.Millisecond)

// test that max sleep is respected
s = time.Now()
RandomSleep(time.Millisecond*50, make(chan struct{}))
elapsed = time.Since(s)
require.True(t, elapsed < time.Millisecond*100)
require.Less(t, elapsed, time.Millisecond*100)

// test that shutdown is respected
s = time.Now()
Expand All @@ -168,7 +168,7 @@ func TestRandomSleep(t *testing.T) {
}()
RandomSleep(time.Second, shutdown)
elapsed = time.Since(s)
require.True(t, elapsed < time.Millisecond*150)
require.Less(t, elapsed, time.Millisecond*150)
}

func TestCompressWithGzip(t *testing.T) {
Expand Down
4 changes: 2 additions & 2 deletions plugins/inputs/pgbouncer/pgbouncer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ func TestPgBouncerGeneratesMetricsIntegration(t *testing.T) {
metricsCounted++
}

require.True(t, metricsCounted > 0)
require.Greater(t, metricsCounted, 0)
require.Equal(t, len(intMetricsPgBouncer)+len(intMetricsPgBouncerPools), metricsCounted)
}

Expand Down Expand Up @@ -208,6 +208,6 @@ func TestPgBouncerGeneratesMetricsIntegrationShowCommands(t *testing.T) {
metricsCounted++
}

require.True(t, metricsCounted > 0)
require.Greater(t, metricsCounted, 0)
require.Equal(t, len(intMetricsPgBouncerPools)+len(intMetricsPgBouncerLists)+len(intMetricsPgBouncerDatabases), metricsCounted)
}
2 changes: 1 addition & 1 deletion plugins/inputs/ping/ping_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -405,7 +405,7 @@ func TestPingBinary(t *testing.T) {
Urls: []string{"www.google.com"},
Binary: "ping6",
pingHost: func(binary string, timeout float64, args ...string) (string, error) {
require.True(t, binary == "ping6")
require.Equal(t, binary, "ping6")
return "", nil
},
}
Expand Down
2 changes: 1 addition & 1 deletion plugins/inputs/postgresql/postgresql_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ func TestPostgresqlGeneratesMetricsIntegration(t *testing.T) {
metricsCounted++
}

require.True(t, metricsCounted > 0)
require.Greater(t, metricsCounted, 0)
require.Equal(t, len(floatMetrics)+len(intMetrics)+len(int32Metrics)+len(stringMetrics), metricsCounted)
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ func TestPostgresqlGeneratesMetricsIntegration(t *testing.T) {
metricsCounted++
}

require.True(t, metricsCounted > 0)
require.Greater(t, metricsCounted, 0)
require.Equal(t, len(floatMetrics)+len(intMetrics)+len(int32Metrics)+len(stringMetrics), metricsCounted)
}

Expand Down
2 changes: 1 addition & 1 deletion plugins/inputs/processes/processes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ func TestProcesses(t *testing.T) {
require.True(t, acc.HasInt64Field("processes", "total"))
total, ok := acc.Get("processes")
require.True(t, ok)
require.True(t, total.Fields["total"].(int64) > 0)
require.Greater(t, total.Fields["total"].(int64), int64(0))
}

func TestFromPS(t *testing.T) {
Expand Down
16 changes: 8 additions & 8 deletions plugins/inputs/prometheus/prometheus_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ func TestPrometheusGeneratesMetrics(t *testing.T) {
require.True(t, acc.HasFloatField("test_metric", "value"))
require.True(t, acc.HasTimestamp("test_metric", time.Unix(1490802350, 0)))
require.False(t, acc.HasTag("test_metric", "address"))
require.True(t, acc.TagValue("test_metric", "url") == ts.URL+"/metrics")
require.Equal(t, acc.TagValue("test_metric", "url"), ts.URL+"/metrics")
}

func TestPrometheusCustomHeader(t *testing.T) {
Expand Down Expand Up @@ -164,8 +164,8 @@ func TestPrometheusGeneratesMetricsWithHostNameTag(t *testing.T) {
require.True(t, acc.HasFloatField("go_goroutines", "gauge"))
require.True(t, acc.HasFloatField("test_metric", "value"))
require.True(t, acc.HasTimestamp("test_metric", time.Unix(1490802350, 0)))
require.True(t, acc.TagValue("test_metric", "address") == tsAddress)
require.True(t, acc.TagValue("test_metric", "url") == ts.URL)
require.Equal(t, acc.TagValue("test_metric", "address"), tsAddress)
require.Equal(t, acc.TagValue("test_metric", "url"), ts.URL)
}

func TestPrometheusWithTimestamp(t *testing.T) {
Expand Down Expand Up @@ -260,7 +260,7 @@ func TestPrometheusGeneratesMetricsSlowEndpoint(t *testing.T) {
require.True(t, acc.HasFloatField("test_metric", "value"))
require.True(t, acc.HasTimestamp("test_metric", time.Unix(1490802350, 0)))
require.False(t, acc.HasTag("test_metric", "address"))
require.True(t, acc.TagValue("test_metric", "url") == ts.URL+"/metrics")
require.Equal(t, acc.TagValue("test_metric", "url"), ts.URL+"/metrics")
}

func TestPrometheusGeneratesMetricsSlowEndpointHitTheTimeout(t *testing.T) {
Expand Down Expand Up @@ -317,7 +317,7 @@ func TestPrometheusGeneratesMetricsSlowEndpointNewConfigParameter(t *testing.T)
require.True(t, acc.HasFloatField("test_metric", "value"))
require.True(t, acc.HasTimestamp("test_metric", time.Unix(1490802350, 0)))
require.False(t, acc.HasTag("test_metric", "address"))
require.True(t, acc.TagValue("test_metric", "url") == ts.URL+"/metrics")
require.Equal(t, acc.TagValue("test_metric", "url"), ts.URL+"/metrics")
}

func TestPrometheusGeneratesMetricsSlowEndpointHitTheTimeoutNewConfigParameter(t *testing.T) {
Expand Down Expand Up @@ -364,10 +364,10 @@ func TestPrometheusGeneratesSummaryMetricsV2(t *testing.T) {
err = acc.GatherError(p.Gather)
require.NoError(t, err)

require.True(t, acc.TagSetValue("prometheus", "quantile") == "0")
require.Equal(t, acc.TagSetValue("prometheus", "quantile"), "0")
require.True(t, acc.HasFloatField("prometheus", "go_gc_duration_seconds_sum"))
require.True(t, acc.HasFloatField("prometheus", "go_gc_duration_seconds_count"))
require.True(t, acc.TagValue("prometheus", "url") == ts.URL+"/metrics")
require.Equal(t, acc.TagValue("prometheus", "url"), ts.URL+"/metrics")
}

func TestSummaryMayContainNaN(t *testing.T) {
Expand Down Expand Up @@ -459,7 +459,7 @@ func TestPrometheusGeneratesGaugeMetricsV2(t *testing.T) {
require.NoError(t, err)

require.True(t, acc.HasFloatField("prometheus", "go_goroutines"))
require.True(t, acc.TagValue("prometheus", "url") == ts.URL+"/metrics")
require.Equal(t, acc.TagValue("prometheus", "url"), ts.URL+"/metrics")
require.True(t, acc.HasTimestamp("prometheus", time.Unix(1490802350, 0)))
}

Expand Down
2 changes: 1 addition & 1 deletion plugins/inputs/vsphere/vsphere_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,7 @@ func testCollection(t *testing.T, excludeClusters bool) {
defer v.Stop()
require.NoError(t, v.Gather(&acc))
require.Equal(t, 0, len(acc.Errors), fmt.Sprintf("Errors found: %s", acc.Errors))
require.True(t, len(acc.Metrics) > 0, "No metrics were collected")
require.Greater(t, len(acc.Metrics), 0, "No metrics were collected")
cache := make(map[string]string)
client, err := v.endpoints[0].clientFactory.GetClient(context.Background())
require.NoError(t, err)
Expand Down
8 changes: 4 additions & 4 deletions plugins/parsers/json/parser_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -672,7 +672,7 @@ func TestTimeParser(t *testing.T) {
metrics, err := parser.Parse([]byte(testString))
require.NoError(t, err)
require.Equal(t, 2, len(metrics))
require.False(t, metrics[0].Time() == metrics[1].Time())
require.NotEqual(t, metrics[0].Time(), metrics[1].Time())
}

func TestTimeParserWithTimezone(t *testing.T) {
Expand Down Expand Up @@ -726,7 +726,7 @@ func TestUnixTimeParser(t *testing.T) {
metrics, err := parser.Parse([]byte(testString))
require.NoError(t, err)
require.Equal(t, 2, len(metrics))
require.False(t, metrics[0].Time() == metrics[1].Time())
require.NotEqual(t, metrics[0].Time(), metrics[1].Time())
}

func TestUnixMsTimeParser(t *testing.T) {
Expand Down Expand Up @@ -761,7 +761,7 @@ func TestUnixMsTimeParser(t *testing.T) {
metrics, err := parser.Parse([]byte(testString))
require.NoError(t, err)
require.Equal(t, 2, len(metrics))
require.False(t, metrics[0].Time() == metrics[1].Time())
require.NotEqual(t, metrics[0].Time(), metrics[1].Time())
}

func TestTimeErrors(t *testing.T) {
Expand Down Expand Up @@ -815,7 +815,7 @@ func TestShareTimestamp(t *testing.T) {
metrics, err := parser.Parse([]byte(validJSONArrayMultiple))
require.NoError(t, err)
require.Equal(t, 2, len(metrics))
require.True(t, metrics[0].Time() == metrics[1].Time())
require.Equal(t, metrics[0].Time(), metrics[1].Time())
}

func TestNameKey(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion plugins/processors/starlark/starlark_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -3375,7 +3375,7 @@ func parseErrorMessage(t *testing.T, lines []string, header string) string {
if startIdx == -1 {
return ""
}
require.True(t, startIdx < len(lines), fmt.Sprintf("Expected to find the error message after %q, but found none", header))
require.Less(t, startIdx, len(lines), fmt.Sprintf("Expected to find the error message after %q, but found none", header))
return strings.TrimLeft(lines[startIdx], "# ")
}

Expand Down

0 comments on commit 1ac26be

Please sign in to comment.