diff --git a/envtestutils/envtestutils.go b/envtestutils/envtestutils.go index 079b0bc..0f31408 100644 --- a/envtestutils/envtestutils.go +++ b/envtestutils/envtestutils.go @@ -22,6 +22,7 @@ import ( "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/util/wait" + corev1ac "k8s.io/client-go/applyconfigurations/core/v1" "k8s.io/client-go/rest" apiregistrationv1 "k8s.io/kube-aggregator/pkg/apis/apiregistration/v1" "k8s.io/utils/ptr" @@ -157,21 +158,12 @@ func (o *APIServiceInstallOptions) generateService(cfg *rest.Config) (namespace, name = "aggregated-apiserver" } - service := &corev1.Service{ - TypeMeta: metav1.TypeMeta{ - APIVersion: corev1.SchemeGroupVersion.String(), - Kind: "Service", - }, - ObjectMeta: metav1.ObjectMeta{ - Namespace: namespace, - Name: name, - }, - Spec: corev1.ServiceSpec{ - Type: corev1.ServiceTypeExternalName, - ExternalName: host, - }, - } - if err := c.Patch(ctx, service, client.Apply, client.ForceOwnership, fieldOwner); err != nil { + serviceAC := corev1ac.Service(name, namespace). + WithSpec(corev1ac.ServiceSpec(). + WithType(corev1.ServiceTypeExternalName). + WithExternalName(host), + ) + if err := c.Apply(ctx, serviceAC, client.ForceOwnership, fieldOwner); err != nil { return "", "", fmt.Errorf("error applying service: %w", err) }