chore: Wrap long lines in plugins/processors (#12181)
This commit is contained in:
parent
59966d390c
commit
979eec8fb8
|
|
@ -116,7 +116,11 @@ func TestMappings(t *testing.T) {
|
||||||
for _, mapping := range mappings {
|
for _, mapping := range mappings {
|
||||||
fieldName := mapping["field_name"][0].(string)
|
fieldName := mapping["field_name"][0].(string)
|
||||||
for index := range mapping["target_value"] {
|
for index := range mapping["target_value"] {
|
||||||
mapper := EnumMapper{Mappings: []Mapping{{Field: fieldName, ValueMappings: map[string]interface{}{mapping["target_value"][index].(string): mapping["mapped_value"][index]}}}}
|
mapper := EnumMapper{
|
||||||
|
Mappings: []Mapping{
|
||||||
|
{Field: fieldName, ValueMappings: map[string]interface{}{mapping["target_value"][index].(string): mapping["mapped_value"][index]}},
|
||||||
|
},
|
||||||
|
}
|
||||||
err := mapper.Init()
|
err := mapper.Init()
|
||||||
require.Nil(t, err)
|
require.Nil(t, err)
|
||||||
fields := calculateProcessedValues(mapper, createTestMetric())
|
fields := calculateProcessedValues(mapper, createTestMetric())
|
||||||
|
|
|
||||||
|
|
@ -213,7 +213,9 @@ func TestApply(t *testing.T) {
|
||||||
"success",
|
"success",
|
||||||
map[string]string{},
|
map[string]string{},
|
||||||
map[string]interface{}{
|
map[string]interface{}{
|
||||||
"grokSample": "127.0.0.1 - - [11/Dec/2013:00:01:45 -0800] \"GET /xampp/status.php HTTP/1.1\" 200 3891 \"http://cadenza/xampp/navi.php\" \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10.9; rv:25.0) Gecko/20100101 Firefox/25.0\"",
|
"grokSample": "127.0.0.1 - - [11/Dec/2013:00:01:45 -0800] \"" +
|
||||||
|
"GET /xampp/status.php HTTP/1.1\" 200 3891 \"http://cadenza/xampp/navi.php\" \"Mozilla/5.0 (Macintosh; " +
|
||||||
|
"Intel Mac OS X 10.9; rv:25.0) Gecko/20100101 Firefox/25.0\"",
|
||||||
},
|
},
|
||||||
time.Unix(0, 0)),
|
time.Unix(0, 0)),
|
||||||
expected: []telegraf.Metric{
|
expected: []telegraf.Metric{
|
||||||
|
|
|
||||||
|
|
@ -1,15 +1,14 @@
|
||||||
package regex
|
package regex
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/influxdata/telegraf/metric"
|
|
||||||
"github.com/stretchr/testify/assert"
|
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/influxdata/telegraf"
|
|
||||||
"github.com/influxdata/telegraf/testutil"
|
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
|
|
||||||
|
"github.com/influxdata/telegraf"
|
||||||
|
"github.com/influxdata/telegraf/metric"
|
||||||
|
"github.com/influxdata/telegraf/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
func newM1() telegraf.Metric {
|
func newM1() telegraf.Metric {
|
||||||
|
|
@ -880,8 +879,8 @@ func TestAnyTagConversion(t *testing.T) {
|
||||||
"request": "/users/42/",
|
"request": "/users/42/",
|
||||||
}
|
}
|
||||||
|
|
||||||
assert.Equal(t, expectedFields, processed[0].Fields(), test.message, "Should not change fields")
|
require.Equal(t, expectedFields, processed[0].Fields(), test.message, "Should not change fields")
|
||||||
assert.Equal(t, test.expectedTags, processed[0].Tags(), test.message)
|
require.Equal(t, test.expectedTags, processed[0].Tags(), test.message)
|
||||||
assert.Equal(t, "access_log", processed[0].Name(), "Should not change name")
|
require.Equal(t, "access_log", processed[0].Name(), "Should not change name")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -65,7 +65,9 @@ func TestTagTemplateConcatenate(t *testing.T) {
|
||||||
actual := tmp.Apply(input[0])
|
actual := tmp.Apply(input[0])
|
||||||
|
|
||||||
// assert
|
// assert
|
||||||
expected := []telegraf.Metric{testutil.MustMetric("Tags", map[string]string{"hostname": "localhost", "level": "debug", "topic": "localhost.debug"}, nil, now)}
|
expected := []telegraf.Metric{
|
||||||
|
testutil.MustMetric("Tags", map[string]string{"hostname": "localhost", "level": "debug", "topic": "localhost.debug"}, nil, now),
|
||||||
|
}
|
||||||
testutil.RequireMetricsEqual(t, expected, actual)
|
testutil.RequireMetricsEqual(t, expected, actual)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -112,7 +114,14 @@ func TestTagAndFieldConcatenate(t *testing.T) {
|
||||||
actual := tmp.Apply(m1)
|
actual := tmp.Apply(m1)
|
||||||
|
|
||||||
// assert
|
// assert
|
||||||
expected := []telegraf.Metric{testutil.MustMetric("weather", map[string]string{"location": "us-midwest", "LocalTemp": "us-midwest is too warm"}, map[string]interface{}{"temperature": "too warm"}, now)}
|
expected := []telegraf.Metric{
|
||||||
|
testutil.MustMetric(
|
||||||
|
"weather",
|
||||||
|
map[string]string{"location": "us-midwest", "LocalTemp": "us-midwest is too warm"},
|
||||||
|
map[string]interface{}{"temperature": "too warm"},
|
||||||
|
now,
|
||||||
|
),
|
||||||
|
}
|
||||||
testutil.RequireMetricsEqual(t, expected, actual)
|
testutil.RequireMetricsEqual(t, expected, actual)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue