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())
 	}

test/utilities/deepcopy.go

@@ -0,0 +1,32 @@
+package utilities
+
+import "k8s.io/apimachinery/pkg/runtime"
+
+// DeepCopyInto copies all properties of this object into another object of the
+// same type that is provided as a pointer.
+func (in *Resourse) DeepCopyInto(out *Resourse) {
+	out.TypeMeta = in.TypeMeta
+	out.ObjectMeta = in.ObjectMeta
+	out.Spec = in.Spec
+	out.Status = in.Status
+}
+
+// DeepCopyObject returns a generically typed copy of an object
+func (in *Resourse) DeepCopyObject() runtime.Object {
+	out := Resourse{}
+	in.DeepCopyInto(&out)
+
+	return &out
+}
+
+func (in *ResourseList) DeepCopyObject() runtime.Object {
+	out := ResourseList{}
+	if in.Items != nil {
+		out.Items = make([]Resourse, len(in.Items))
+		for i := range in.Items {
+			in.Items[i].DeepCopyInto(&out.Items[i])
+		}
+	}
+
+	return &out
+}

test/utilities/object.go

@@ -0,0 +1,18 @@
+package utilities
+
+import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+type Resourse struct {
+	metav1.TypeMeta `json:",inline"`
+
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec map[string]any `json:"spec"`
+
+	Status map[string]any `json:"status"`
+}
+
+type ResourseList struct {
+	metav1.TypeMeta `json:",inline"`
+	Items           []Resourse `json:"items"`
+}