gauge_stats_test.go

package main

import (
	"fmt"
	"os"
	"testing"

	"github.com/stretchr/testify/assert"
)

func TestGetGaugesNotEmpty(t *testing.T) {

	// this is to force-reload the config in the NamespaceWatcher, this is a check on this param in NamespaceWatcher implementation
	os.Setenv(TESTCASE_MODE, TESTCASE_MODE_TRUE)

	fmt.Println("initializing GaugeMetrics ... TestGetGaugesNotEmpty")

	// Initialize and validate Gauge config
	gaugeList := new(GaugeStats)

	initGaugeStats(METRICS_CONFIG_FILE, gaugeList)

	nslist := gaugeList.NamespaceStats
	nodelist := gaugeList.NodeStats
	assert.NotEmpty(t, nslist)
	assert.NotEmpty(t, nodelist)
}

func TestGetGaugesCounts(t *testing.T) {

	// this is to force-reload the config in the NamespaceWatcher, this is a check on this param in NamespaceWatcher implementation
	os.Setenv(TESTCASE_MODE, TESTCASE_MODE_TRUE)

	fmt.Println("initializing GaugeMetrics ... TestGetGaugesCounts")

	// Initialize and validate Gauge config
	gaugeList := new(GaugeStats)

	initGaugeStats(METRICS_CONFIG_FILE, gaugeList)

	glist := gaugeList.NamespaceStats
	assert.Equal(t, len(glist), 96)

	glist = gaugeList.NodeStats
	assert.Equal(t, len(glist), 74)

	glist = gaugeList.SetsStats
	assert.Equal(t, len(glist), 7)

	glist = gaugeList.SindexStats
	assert.Equal(t, len(glist), 13)

	glist = gaugeList.XdrStats
	assert.Equal(t, len(glist), 10)

}

func TestIsAGaugeTrue(t *testing.T) {

	// this is to force-reload the config in the NamespaceWatcher, this is a check on this param in NamespaceWatcher implementation
	os.Setenv(TESTCASE_MODE, TESTCASE_MODE_TRUE)

	// Initialize and validate Gauge config
	gaugeList := new(GaugeStats)

	initGaugeStats(METRICS_CONFIG_FILE, gaugeList)

	exists := false

	exists = gaugeList.isGauge(CTX_NAMESPACE, "cache_read_pct")
	assert.Equal(t, exists, true)

	exists = gaugeList.isGauge(CTX_NODE_STATS, "cluster_clock_skew_stop_writes_sec")
	assert.Equal(t, exists, true)

	exists = gaugeList.isGauge(CTX_SINDEX, "entries_per_rec")
	assert.Equal(t, exists, true)

	exists = gaugeList.isGauge(CTX_XDR, "recoveries_pending")
	assert.Equal(t, exists, true)

	exists = gaugeList.isGauge(CTX_SETS, "truncate_lut")
	assert.Equal(t, exists, true)

}

func TestNoGaugeExists(t *testing.T) {

	// this is to force-reload the config in the NamespaceWatcher, this is a check on this param in NamespaceWatcher implementation
	os.Setenv(TESTCASE_MODE, TESTCASE_MODE_TRUE)

	fmt.Println("initializing GaugeMetrics ... TestNoGaugeExists")

	// Initialize and validate Gauge config
	gaugeList := new(GaugeStats)

	initGaugeStats(METRICS_CONFIG_FILE, gaugeList)

	exists := gaugeList.isGauge(CTX_NAMESPACE, "non-existing-key")
	assert.Equal(t, exists, false)
}