Function TestNetworkPluginManagerMetrics

network/plugins_test.go:30–66

(t *testing.T)

)

func TestNetworkPluginManagerMetrics(t *testing.T) {
	metrics.Register()

	operation := "test_operation"
	recordOperation(operation, time.Now())
	recordError(operation)

	cases := []struct {
		metricName string
		want       string
	}{
		{
			metricName: "kubelet_network_plugin_operations_total",
			want: `
# HELP kubelet_network_plugin_operations_total [ALPHA] Cumulative number of network plugin operations by operation type.
# TYPE kubelet_network_plugin_operations_total counter
kubelet_network_plugin_operations_total{operation_type="test_operation"} 1
`,
		},
		{
			metricName: "kubelet_network_plugin_operations_errors_total",
			want: `
# HELP kubelet_network_plugin_operations_errors_total [ALPHA] Cumulative number of network plugin operation errors by operation type.
# TYPE kubelet_network_plugin_operations_errors_total counter
kubelet_network_plugin_operations_errors_total{operation_type="test_operation"} 1
`,
		},
	}

	for _, tc := range cases {
		t.Run(tc.metricName, func(t *testing.T) {
			if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(tc.want), tc.metricName); err != nil {
				t.Fatal(err)
			}
		})
	}
}