52 lines
1.1 KiB
Go
52 lines
1.1 KiB
Go
|
package graylog
|
||
|
|
|
||
|
|
import (
|
||
|
|
"encoding/json"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/stretchr/testify/require"
|
||
|
|
|
||
|
|
"github.com/influxdata/telegraf/metric"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestSerializer(t *testing.T) {
|
||
|
|
m1 := metric.New("testing",
|
||
|
|
map[string]string{
|
||
|
|
"verb": "GET",
|
||
|
|
"host": "hostname",
|
||
|
|
},
|
||
|
|
map[string]interface{}{
|
||
|
|
"full_message": "full",
|
||
|
|
"short_message": "short",
|
||
|
|
"level": "1",
|
||
|
|
"facility": "demo",
|
||
|
|
"line": "42",
|
||
|
|
"file": "graylog.go",
|
||
|
|
},
|
||
|
|
time.Now(),
|
||
|
|
)
|
||
|
|
|
||
|
|
graylog := Graylog{}
|
||
|
|
result, err := graylog.serialize(m1)
|
||
|
|
|
||
|
|
require.NoError(t, err)
|
||
|
|
|
||
|
|
for _, r := range result {
|
||
|
|
obj := make(map[string]interface{})
|
||
|
|
err = json.Unmarshal([]byte(r), &obj)
|
||
|
|
require.NoError(t, err)
|
||
|
|
|
||
|
|
require.Equal(t, "1.1", obj["version"])
|
||
|
|
require.Equal(t, "testing", obj["_name"])
|
||
|
|
require.Equal(t, "GET", obj["_verb"])
|
||
|
|
require.Equal(t, "hostname", obj["host"])
|
||
|
|
require.Equal(t, "full", obj["full_message"])
|
||
|
|
require.Equal(t, "short", obj["short_message"])
|
||
|
|
require.Equal(t, "1", obj["level"])
|
||
|
|
require.Equal(t, "demo", obj["facility"])
|
||
|
|
require.Equal(t, "42", obj["line"])
|
||
|
|
require.Equal(t, "graylog.go", obj["file"])
|
||
|
|
}
|
||
|
|
}
|