diff --git a/plugins/outputs/kinesis/kinesis_test.go b/plugins/outputs/kinesis/kinesis_test.go index b398d7e8a..6b1860abc 100644 --- a/plugins/outputs/kinesis/kinesis_test.go +++ b/plugins/outputs/kinesis/kinesis_test.go @@ -25,6 +25,19 @@ func TestFormatMetric(t *testing.T) { } require.NoError(t, err) + k := &KinesisOutput{ + Format: "json", + } + + valid_json := "{\"fields\":{\"value\":1},\"name\":\"docker\",\"tags\":{\"tag1\":\"value1\"},\"timestamp\":1257894000}" + func_json, err := FormatMetric(k, p) + + if func_json != valid_json { + t.Error("Expected ", valid_json) + t.Error("Found ", func_json) + } + require.NoError(t, err) + k = &KinesisOutput{ Format: "custom", }