Use openshift/client-go as the client tool

openshift/client-go gives us more efficient functions to access cluster

Author: JianLi-RH

test/utilities/connection.go

@@ -5,31 +5,116 @@ import (
 	"fmt"
 	"os"
 
-	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
+
+	configclient "github.com/openshift/client-go/config/clientset/versioned"
+	configclientv1 "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
+	configv1alpha1 "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1alpha1"
+	configv1alpha2 "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1alpha2"
 )
 
-// getKubeClient creates a Kubernetes clientset.
-func getKubeClient() (*kubernetes.Clientset, error) {
+// getKubeConfig get KUBECONFIG file from environment variable
+func getKubeConfig() (*rest.Config, error) {
 	configPath, present := os.LookupEnv("KUBECONFIG")
+	fmt.Print("configPath: ", configPath)
 	if !present {
 		return nil, errors.New("the environment variable KUBECONFIG must be set")
 	}
 	config, err := clientcmd.BuildConfigFromFlags("", configPath)
+	return config, err
+}
+
+// getClient creates a configclient.Clientset instance.
+func getClient() (*configclient.Clientset, error) {
+	config, err := getKubeConfig()
+	if err != nil {
+		return nil, fmt.Errorf("unable to load build config: %w", err)
+	}
+	// Create the Clientset
+	clientset, err := configclient.NewForConfig(config)
+	if err != nil {
+		return nil, fmt.Errorf("unable to create a Kubernetes clientset: %w", err)
+	}
+
+	return clientset, nil
+}
+
+// getV1Client creates a configclientv1.ConfigV1Client instance.
+func getV1Client() (*configclientv1.ConfigV1Client, error) {
+	config, err := getKubeConfig()
 	if err != nil {
 		return nil, fmt.Errorf("unable to load build config: %w", err)
 	}
 	// Create the Clientset
-	clientset, err := kubernetes.NewForConfig(config)
+	clientset, err := configclientv1.NewForConfig(config)
 	if err != nil {
 		return nil, fmt.Errorf("unable to create a Kubernetes clientset: %w", err)
 	}
+
+	return clientset, nil
+}
+
+// getV1alpha1Client creates a configv1alpha1.ConfigV1alpha1Client instance.
+func getV1alpha1Client() (*configv1alpha1.ConfigV1alpha1Client, error) {
+	// Create the Clientset
+	config, err := getKubeConfig()
+	if err != nil {
+		return nil, fmt.Errorf("unable to load build config: %w", err)
+	}
+	clientset, err := configv1alpha1.NewForConfig(config)
+	if err != nil {
+		return nil, fmt.Errorf("unable to create a Kubernetes clientset: %w", err)
+	}
+
 	return clientset, nil
 }
 
-// MustGetKubeClient creates a Kubernetes clientset, or panics on failures.
-func MustGetKubeClient() *kubernetes.Clientset {
-	clientset, err := getKubeClient()
+// getV1alpha2Client creates a configv1alpha2.ConfigV1alpha2Client instance.
+func getV1alpha2Client() (*configv1alpha2.ConfigV1alpha2Client, error) {
+	// Create the Clientset
+	config, err := getKubeConfig()
+	if err != nil {
+		return nil, fmt.Errorf("unable to load build config: %w", err)
+	}
+	clientset, err := configv1alpha2.NewForConfig(config)
+	if err != nil {
+		return nil, fmt.Errorf("unable to create a Kubernetes clientset: %w", err)
+	}
+
+	return clientset, nil
+}
+
+// MustGetClient creates a configclient.Clientset instance, or panics on failures.
+func MustGetClient() *configclient.Clientset {
+	clientset, err := getClient()
+	if err != nil {
+		panic("unable to create a Kubernetes clientset: " + err.Error())
+	}
+	return clientset
+}
+
+// MustGetV1Client creates a configclientv1.ConfigV1Client instance, or panics on failures.
+func MustGetV1Client() *configclientv1.ConfigV1Client {
+	clientset, err := getV1Client()
+	if err != nil {
+		panic("unable to create a Kubernetes clientset: " + err.Error())
+	}
+	return clientset
+}
+
+// MUSTGetV1alpha1Client creates a configv1alpha1.ConfigV1alpha1Client instance, or panics on failures.
+func MUSTGetV1alpha1Client() *configv1alpha1.ConfigV1alpha1Client {
+	clientset, err := getV1alpha1Client()
+	if err != nil {
+		panic("unable to create a Kubernetes clientset: " + err.Error())
+	}
+	return clientset
+}
+
+// MUSTGetV1alpha2Client creates a configv1alpha2.ConfigV1alpha2Client instance, or panics on failures.
+func MUSTGetV1alpha2Client() *configv1alpha2.ConfigV1alpha2Client {
+	clientset, err := getV1alpha2Client()
 	if err != nil {
 		panic("unable to create a Kubernetes clientset: " + err.Error())
 	}