import (
"bytes"
"encoding/json"
- "github.com/stretchr/testify/assert"
- "gopkg.in/yaml.v2"
"io/ioutil"
"os"
"testing"
"time"
+
+ "github.com/stretchr/testify/assert"
+ "gopkg.in/yaml.v2"
)
func testBaseConf(t *testing.T, vesconf VESAgentConfiguration) {
}
func TestParseMetricsRules(t *testing.T) {
- metricsJson := `{"metrics": [
+ metricsJSON := `{"metrics": [
{ "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounter", "objectInstance": "ricxappRMRReceived" },
{ "name": "ricxapp_RMR_ReceiveError", "objectName": "ricxappRMRReceiveErrorCounter", "objectInstance": "ricxappRMRReceiveError" },
{ "name": "ricxapp_RMR_Transmitted", "objectName": "ricxappRMRTransmittedCounter", "objectInstance": "ricxappRMRTransmitted" },
{ "name": "ricxapp_SDL_Stored", "objectName": "ricxappSDLStoredCounter", "objectInstance": "ricxappSDLStored" },
{ "name": "ricxapp_SDL_StoreError", "objectName": "ricxappSDLStoreErrorCounter", "objectInstance": "ricxappSDLStoreError" } ]}`
appMetrics := make(AppMetrics)
- var m []interface{} = metricsStringToInterfaceArray(metricsJson)
+ m := metricsStringToInterfaceArray(metricsJSON)
appMetrics = parseMetricsRules(m, appMetrics)
assert.Len(t, appMetrics, 6)
assert.Equal(t, "ricxappRMRreceivedCounter", appMetrics["ricxapp_RMR_Received"].ObjectName)
func TestParseMetricsRulesNoMetrics(t *testing.T) {
appMetrics := make(AppMetrics)
- metricsJson := `{"metrics": []`
- var m []interface{} = metricsStringToInterfaceArray(metricsJson)
+ metricsJSON := `{"metrics": []`
+ m := metricsStringToInterfaceArray(metricsJSON)
appMetrics = parseMetricsRules(m, appMetrics)
assert.Empty(t, appMetrics)
}
func TestParseMetricsRulesAdditionalFields(t *testing.T) {
appMetrics := make(AppMetrics)
- metricsJson := `{"metrics": [
+ metricsJSON := `{"metrics": [
{ "additionalField": "valueIgnored", "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounter", "objectInstance": "ricxappRMRReceived" }]}`
- var m []interface{} = metricsStringToInterfaceArray(metricsJson)
+ m := metricsStringToInterfaceArray(metricsJSON)
appMetrics = parseMetricsRules(m, appMetrics)
assert.Len(t, appMetrics, 1)
assert.Equal(t, "ricxappRMRreceivedCounter", appMetrics["ricxapp_RMR_Received"].ObjectName)
func TestParseMetricsRulesMissingFields(t *testing.T) {
appMetrics := make(AppMetrics)
- metricsJson := `{"metrics": [
+ metricsJSON := `{"metrics": [
{ "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounter", "objectInstance": "ricxappRMRReceived" },
{ "name": "ricxapp_RMR_ReceiveError", "objectInstance": "ricxappRMRReceiveError" },
{ "name": "ricxapp_RMR_Transmitted", "objectName": "ricxappRMRTransmittedCounter", "objectInstance": "ricxappRMRTransmitted" }]}`
- var m []interface{} = metricsStringToInterfaceArray(metricsJson)
+ m := metricsStringToInterfaceArray(metricsJSON)
appMetrics = parseMetricsRules(m, appMetrics)
assert.Len(t, appMetrics, 2)
assert.Equal(t, "ricxappRMRreceivedCounter", appMetrics["ricxapp_RMR_Received"].ObjectName)
func TestParseMetricsRulesDuplicateDefinitionIsIgnored(t *testing.T) {
appMetrics := make(AppMetrics)
- metricsJson := `{"metrics": [
+ metricsJSON := `{"metrics": [
{ "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounter", "objectInstance": "ricxappRMRReceived" },
{ "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounterXXX", "objectInstance": "ricxappRMRReceivedXXX" },
{ "name": "ricxapp_RMR_Transmitted", "objectName": "ricxappRMRTransmittedCounter", "objectInstance": "ricxappRMRTransmitted" }]}`
- var m []interface{} = metricsStringToInterfaceArray(metricsJson)
+ m := metricsStringToInterfaceArray(metricsJSON)
appMetrics = parseMetricsRules(m, appMetrics)
assert.Len(t, appMetrics, 2)
assert.Equal(t, "ricxappRMRreceivedCounter", appMetrics["ricxapp_RMR_Received"].ObjectName)
func TestParseMetricsRulesIncrementalFillOfAppMetrics(t *testing.T) {
appMetrics := make(AppMetrics)
- metricsJson1 := `{"metrics": [
+ metricsJSON1 := `{"metrics": [
{ "name": "ricxapp_RMR_Received", "objectName": "ricxappRMRreceivedCounter", "objectInstance": "ricxappRMRReceived" }]}`
- metricsJson2 := `{"metrics": [
+ metricsJSON2 := `{"metrics": [
{ "name": "ricxapp_RMR_Transmitted", "objectName": "ricxappRMRTransmittedCounter", "objectInstance": "ricxappRMRTransmitted" }]}`
- var m1 []interface{} = metricsStringToInterfaceArray(metricsJson1)
- var m2 []interface{} = metricsStringToInterfaceArray(metricsJson2)
+ m1 := metricsStringToInterfaceArray(metricsJSON1)
+ m2 := metricsStringToInterfaceArray(metricsJSON2)
appMetrics = parseMetricsRules(m1, appMetrics)
appMetrics = parseMetricsRules(m2, appMetrics)
assert.Len(t, appMetrics, 2)
}
func TestParseXAppDescriptorWithNoConfig(t *testing.T) {
- metricsJson := `[{{"metadata": "something", "descriptor": "somethingelse"}},
+ metricsJSON := `[{{"metadata": "something", "descriptor": "somethingelse"}},
{{"metadata": "something", "descriptor": "somethingelse"}}]`
- metricsBytes := []byte(metricsJson)
+ metricsBytes := []byte(metricsJSON)
appMetrics := make(AppMetrics)
appMetrics = parseMetricsFromXAppDescriptor(metricsBytes, appMetrics)
assert.Empty(t, appMetrics)
}
func TestParseXAppDescriptorWithNoMetrics(t *testing.T) {
- metricsJson := `[{{"metadata": "something", "descriptor": "somethingelse", "config":{}},
+ metricsJSON := `[{{"metadata": "something", "descriptor": "somethingelse", "config":{}},
{{"metadata": "something", "descriptor": "somethingelse", "config":{}}}]`
- metricsBytes := []byte(metricsJson)
+ metricsBytes := []byte(metricsJSON)
appMetrics := make(AppMetrics)
appMetrics = parseMetricsFromXAppDescriptor(metricsBytes, appMetrics)
assert.Empty(t, appMetrics)