17623624479

Committed 10 Sep 2025 06:40PM UTC coverage: 79.35% (-1.9%) from 81.213%

Build # 17623624479

Build Type

push

github

Committed by

OliverMKing

Commit Message

fix keyvault cloud parameter

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

94 existing lines in 3 files now uncovered.

4004 of 5046 relevant lines covered (79.35%)

21.72 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/controller/testutils/testutils.go

package testutils

import (
        "path/filepath"
        "testing"

        approutingv1alpha1 "github.com/Azure/aks-app-routing-operator/api/v1alpha1"
        "github.com/Azure/aks-app-routing-operator/pkg/controller/controllername"
        "github.com/Azure/aks-app-routing-operator/pkg/controller/metrics"
        cfgv1alpha2 "github.com/openservicemesh/osm/pkg/apis/config/v1alpha2"
        policyv1alpha1 "github.com/openservicemesh/osm/pkg/apis/policy/v1alpha1"
        promDTO "github.com/prometheus/client_model/go"
        "github.com/stretchr/testify/require"
        apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
        "k8s.io/apimachinery/pkg/runtime"
        utilruntime "k8s.io/apimachinery/pkg/util/runtime"
        clientgoscheme "k8s.io/client-go/kubernetes/scheme"
        "k8s.io/client-go/rest"
        "sigs.k8s.io/controller-runtime/pkg/client/fake"
        "sigs.k8s.io/controller-runtime/pkg/envtest"
        gatewayv1 "sigs.k8s.io/gateway-api/apis/v1"
        secv1 "sigs.k8s.io/secrets-store-csi-driver/apis/v1"
)

func GetErrMetricCount(t *testing.T, controllerName controllername.ControllerNamer) float64 {
        errMetric, err := metrics.AppRoutingReconcileErrors.GetMetricWithLabelValues(controllerName.MetricsName())
        require.NoError(t, err)

        metricProto := &promDTO.Metric{}

        err = errMetric.Write(metricProto)
        require.NoError(t, err)

        beforeCount := metricProto.GetCounter().GetValue()
        return beforeCount
}

func GetReconcileMetricCount(t *testing.T, controllerName controllername.ControllerNamer, label string) float64 {
        errMetric, err := metrics.AppRoutingReconcileTotal.GetMetricWithLabelValues(controllerName.MetricsName(), label)
        require.NoError(t, err)

        metricProto := &promDTO.Metric{}

        err = errMetric.Write(metricProto)
        require.NoError(t, err)

        beforeCount := metricProto.GetCounter().GetValue()
        return beforeCount
}

func StartTestingEnv() (*rest.Config, *envtest.Environment, error) {
        env := &envtest.Environment{}
        restConfig, err := env.Start()
        if err != nil {
                return nil, nil, err
        }
        return restConfig, env, nil
}

func CleanupTestingEnv(env *envtest.Environment) error {
        return env.Stop()
}

func RegisterSchemes(t *testing.T, builder *fake.ClientBuilder, regFuncs ...func(s *runtime.Scheme) error) *fake.ClientBuilder {
        scheme := runtime.NewScheme()
        for _, regFunc := range regFuncs {
                require.NoError(t, regFunc(scheme))
        }

        return builder.WithScheme(scheme)
}

func NewTestScheme() *runtime.Scheme {
        s := runtime.NewScheme()
        utilruntime.Must(clientgoscheme.AddToScheme(s))
        utilruntime.Must(secv1.Install(s))
        utilruntime.Must(cfgv1alpha2.AddToScheme(s))
        utilruntime.Must(policyv1alpha1.AddToScheme(s))
        utilruntime.Must(approutingv1alpha1.AddToScheme(s))
        utilruntime.Must(apiextensionsv1.AddToScheme(s))
        utilruntime.Must(gatewayv1.Install(s))
        return s
}

func NewTestEnvironment() *envtest.Environment {
        return &envtest.Environment{
                CRDDirectoryPaths: []string{
                        filepath.Join("..", "..", "config", "crd", "bases"),
                        filepath.Join("..", "..", "config", "gatewaycrd"),
                },
        }
}

1	package testutils
2
3	import (
4	"path/filepath"
5	"testing"
6
7	approutingv1alpha1 "github.com/Azure/aks-app-routing-operator/api/v1alpha1"
8	"github.com/Azure/aks-app-routing-operator/pkg/controller/controllername"
9	"github.com/Azure/aks-app-routing-operator/pkg/controller/metrics"
10	cfgv1alpha2 "github.com/openservicemesh/osm/pkg/apis/config/v1alpha2"
11	policyv1alpha1 "github.com/openservicemesh/osm/pkg/apis/policy/v1alpha1"
12	promDTO "github.com/prometheus/client_model/go"
13	"github.com/stretchr/testify/require"
14	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
15	"k8s.io/apimachinery/pkg/runtime"
16	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
17	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
18	"k8s.io/client-go/rest"
19	"sigs.k8s.io/controller-runtime/pkg/client/fake"
20	"sigs.k8s.io/controller-runtime/pkg/envtest"
21	gatewayv1 "sigs.k8s.io/gateway-api/apis/v1"
22	secv1 "sigs.k8s.io/secrets-store-csi-driver/apis/v1"
23	)
24
UNCOV 25	func GetErrMetricCount(t *testing.T, controllerName controllername.ControllerNamer) float64 {	×
UNCOV 26	errMetric, err := metrics.AppRoutingReconcileErrors.GetMetricWithLabelValues(controllerName.MetricsName())	×
UNCOV 27	require.NoError(t, err)	×
UNCOV 28		×
UNCOV 29	metricProto := &promDTO.Metric{}	×
UNCOV 30		×
UNCOV 31	err = errMetric.Write(metricProto)	×
UNCOV 32	require.NoError(t, err)	×
UNCOV 33		×
UNCOV 34	beforeCount := metricProto.GetCounter().GetValue()	×
UNCOV 35	return beforeCount	×
UNCOV 36	}	×
37
UNCOV 38	func GetReconcileMetricCount(t *testing.T, controllerName controllername.ControllerNamer, label string) float64 {	×
UNCOV 39	errMetric, err := metrics.AppRoutingReconcileTotal.GetMetricWithLabelValues(controllerName.MetricsName(), label)	×
UNCOV 40	require.NoError(t, err)	×
UNCOV 41		×
UNCOV 42	metricProto := &promDTO.Metric{}	×
UNCOV 43		×
UNCOV 44	err = errMetric.Write(metricProto)	×
UNCOV 45	require.NoError(t, err)	×
UNCOV 46		×
UNCOV 47	beforeCount := metricProto.GetCounter().GetValue()	×
UNCOV 48	return beforeCount	×
UNCOV 49	}	×
50
UNCOV 51	func StartTestingEnv() (rest.Config, envtest.Environment, error) {	×
UNCOV 52	env := &envtest.Environment{}	×
UNCOV 53	restConfig, err := env.Start()	×
UNCOV 54	if err != nil {	×
55	return nil, nil, err	×
56	}	×
UNCOV 57	return restConfig, env, nil	×
58	}
59
60	func CleanupTestingEnv(env *envtest.Environment) error {	×
61	return env.Stop()	×
62	}	×
63
UNCOV 64	func RegisterSchemes(t testing.T, builder fake.ClientBuilder, regFuncs ...func(s runtime.Scheme) error) fake.ClientBuilder {	×
UNCOV 65	scheme := runtime.NewScheme()	×
UNCOV 66	for _, regFunc := range regFuncs {	×
UNCOV 67	require.NoError(t, regFunc(scheme))	×
UNCOV 68	}	×
69
UNCOV 70	return builder.WithScheme(scheme)	×
71	}
72
UNCOV 73	func NewTestScheme() *runtime.Scheme {	×
UNCOV 74	s := runtime.NewScheme()	×
UNCOV 75	utilruntime.Must(clientgoscheme.AddToScheme(s))	×
UNCOV 76	utilruntime.Must(secv1.Install(s))	×
UNCOV 77	utilruntime.Must(cfgv1alpha2.AddToScheme(s))	×
UNCOV 78	utilruntime.Must(policyv1alpha1.AddToScheme(s))	×
UNCOV 79	utilruntime.Must(approutingv1alpha1.AddToScheme(s))	×
UNCOV 80	utilruntime.Must(apiextensionsv1.AddToScheme(s))	×
UNCOV 81	utilruntime.Must(gatewayv1.Install(s))	×
UNCOV 82	return s	×
UNCOV 83	}	×
84
UNCOV 85	func NewTestEnvironment() *envtest.Environment {	×
UNCOV 86	return &envtest.Environment{	×
UNCOV 87	CRDDirectoryPaths: []string{	×
UNCOV 88	filepath.Join("..", "..", "config", "crd", "bases"),	×
UNCOV 89	filepath.Join("..", "..", "config", "gatewaycrd"),	×
UNCOV 90	},	×
UNCOV 91	}	×
UNCOV 92	}	×

Azure / aks-app-routing-operator / 17623624479

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous