host_metrics_test.go

// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0

package grafanacloudconnector

import (
	"strings"
	"testing"

	"gotest.tools/assert"
)

func TestHostMetrics(t *testing.T) {
	for _, tc := range []struct {
		name                   string
		hosts                  []string
		expectedHostCount      int
		expectedMetricCount    int
		expectedDatapointCount int
	}{
		{
			name:                   "single host",
			hosts:                  []string{"hostA"},
			expectedHostCount:      1,
			expectedMetricCount:    1,
			expectedDatapointCount: 1,
		},
		{
			name:                   "multiple hosts",
			hosts:                  []string{"hostA", "hostB", "hostC", "hostA", "hostB"},
			expectedHostCount:      3,
			expectedMetricCount:    1,
			expectedDatapointCount: 3,
		},
		{
			name:  "none",
			hosts: []string{},
		},
	} {
		t.Run(tc.name, func(t *testing.T) {
			hm := newHostMetrics()
			for _, h := range tc.hosts {
				hm.add(h)
			}

			metrics, count := hm.metrics()
			hm.reset()
			assert.Equal(t, tc.expectedHostCount, count)
			if metrics != nil {
				assert.Equal(t, tc.expectedMetricCount, metrics.MetricCount())
				assert.Equal(t, tc.expectedDatapointCount, metrics.DataPointCount())
				rm := metrics.ResourceMetrics()
				metric := rm.At(0).ScopeMetrics().At(0).Metrics().At(0)
				assert.Equal(t, hostInfoMetric, metric.Name())
				for i := 0; i < count; i++ {
					dp := metric.Gauge().DataPoints().At(i)
					val, ok := dp.Attributes().Get(hostIdentifierAttr)
					assert.Assert(t, ok)
					assert.Assert(t, strings.HasPrefix(val.AsString(), "host"))
					assert.Equal(t, int64(1), dp.IntValue())
				}
			}
		})
	}
}