test/extended/controller_manager/deploy_scale.go - main - githubmirror/origin

test/extended/controller_manager/deploy_scale.go
116 строк4 KB
bparees
Switch imports to ginkgo v2
07 ноя 2022, 15:21
07 ноя 2022, 15:2198d9c70
package controller_manager

import (
	"context"
	"fmt"
	"time"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
	"k8s.io/apimachinery/pkg/util/wait"
	discocache "k8s.io/client-go/discovery/cached"
	"k8s.io/client-go/dynamic"
	"k8s.io/client-go/restmapper"
	"k8s.io/client-go/scale"

	g "github.com/onsi/ginkgo/v2"
	"github.com/openshift/api/apps"
	appsv1 "github.com/openshift/api/apps/v1"
	appsv1client "github.com/openshift/client-go/apps/clientset/versioned"
	"github.com/openshift/library-go/pkg/apps/appsutil"
	exutil "github.com/openshift/origin/test/extended/util"
)

var _ = g.Describe("[sig-apps][Feature:OpenShiftControllerManager]", func() {
	defer g.GinkgoRecover()
	oc := exutil.NewCLI("deployment-scale")

	g.It("TestDeployScale [apigroup:apps.openshift.io]", func() {
		t := g.GinkgoT()

		namespace := oc.Namespace()
		adminAppsClient := oc.AppsClient()

		config := OkDeploymentConfig(0)
		config.Namespace = namespace
		config.Spec.Triggers = []appsv1.DeploymentTriggerPolicy{}
		config.Spec.Replicas = 1

		dc, err := adminAppsClient.AppsV1().DeploymentConfigs(namespace).Create(context.Background(), config, metav1.CreateOptions{})
		if err != nil {
			t.Fatalf("Couldn't create DeploymentConfig: %v %#v", err, config)
		}
		generation := dc.Generation

		{
			appsClient := appsv1client.NewForConfigOrDie(oc.UserConfig())
			// Get scale subresource
			scalePath := fmt.Sprintf("/apis/apps.openshift.io/v1/namespaces/%s/deploymentconfigs/%s/scale", dc.Namespace, dc.Name)
			scale := &unstructured.Unstructured{}
			if err := appsClient.RESTClient().Get().AbsPath(scalePath).Do(context.Background()).Into(scale); err != nil {
				t.Fatal(err)
			}
			// Ensure correct type
			if scale.GetAPIVersion() != "extensions/v1beta1" {
				t.Fatalf("Expected extensions/v1beta1, got %v", scale.GetAPIVersion())
			}
			scaleBytes, err := scale.MarshalJSON()
			if err != nil {
				t.Fatal(err)
			}

			// Ensure we can submit the same type back
			if err := appsClient.RESTClient().Put().AbsPath(scalePath).Body(scaleBytes).Do(context.Background()).Error(); err != nil {
				t.Fatal(err)
			}
		}

		condition := func() (bool, error) {
			config, err := adminAppsClient.AppsV1().DeploymentConfigs(namespace).Get(context.Background(), dc.Name, metav1.GetOptions{})
			if err != nil {
				return false, nil
			}
			return appsutil.HasSynced(config, generation), nil
		}
		if err := wait.PollImmediate(500*time.Millisecond, 10*time.Second, condition); err != nil {
			t.Fatalf("Deployment config never synced: %v", err)
		}

		restMapper := restmapper.NewDeferredDiscoveryRESTMapper(discocache.NewMemCacheClient(adminAppsClient.Discovery()))
		restMapper.Reset()
		// we don't use cached discovery because DiscoveryScaleKindResolver does its own caching,
		// so we want to re-fetch every time when we actually ask for it
		scaleKindResolver := scale.NewDiscoveryScaleKindResolver(adminAppsClient.Discovery())
		scaleClient, err := scale.NewForConfig(oc.UserConfig(), restMapper, dynamic.LegacyAPIPathResolverFunc, scaleKindResolver)
		if err != nil {
			t.Fatal(err)
		}

		scale, err := scaleClient.Scales(namespace).Get(context.Background(), apps.Resource("deploymentconfigs"), config.Name, metav1.GetOptions{})
		if err != nil {
			t.Fatalf("Couldn't get DeploymentConfig scale: %v", err)
		}
		if scale.Spec.Replicas != 1 {
			t.Fatalf("Expected scale.spec.replicas=1, got %#v", scale)
		}

		scaleUpdate := scale.DeepCopy()
		scaleUpdate.Spec.Replicas = 3
		updatedScale, err := scaleClient.Scales(namespace).Update(context.Background(), apps.Resource("deploymentconfigs"), scaleUpdate, metav1.UpdateOptions{})
		if err != nil {
			// If this complains about "Scale" not being registered in "v1", check the kind overrides in the API registration in SubresourceGroupVersionKind
			t.Fatalf("Couldn't update DeploymentConfig scale to %#v: %v", scaleUpdate, err)
		}
		if updatedScale.Spec.Replicas != 3 {
			t.Fatalf("Expected scale.spec.replicas=3, got %#v", scale)
		}

		persistedScale, err := scaleClient.Scales(namespace).Get(context.Background(), apps.Resource("deploymentconfigs"), config.Name, metav1.GetOptions{})
		if err != nil {
			t.Fatalf("Couldn't get DeploymentConfig scale: %v", err)
		}
		if persistedScale.Spec.Replicas != 3 {
			t.Fatalf("Expected scale.spec.replicas=3, got %#v", scale)
		}
	})
})