diff --git a/pkg/apis/cluster/v1beta1/types.go b/pkg/apis/cluster/v1beta1/types.go
index 7936f5ff..fcc8da48 100644
--- a/pkg/apis/cluster/v1beta1/types.go
+++ b/pkg/apis/cluster/v1beta1/types.go
@@ -23,7 +23,6 @@ type CredentialType string
 const (
 	CredentialTypeServiceAccountToken CredentialType = "ServiceAccountToken"
 	CredentialTypeX509Certificate     CredentialType = "X509Certificate"
-	CredentialTypeUnifiedIdentity     CredentialType = "UnifiedIdentity"
 )
 
 // +genclient
diff --git a/pkg/clusterinstall/cluster_install.go b/pkg/clusterinstall/cluster_install.go
new file mode 100644
index 00000000..ce27da12
--- /dev/null
+++ b/pkg/clusterinstall/cluster_install.go
@@ -0,0 +1,71 @@
+package clusterinstall
+
+import (
+	"context"
+	"fmt"
+
+	clusterv1beta1 "github.com/KusionStack/karbour/pkg/apis/cluster/v1beta1"
+	"github.com/KusionStack/karbour/pkg/generated/clientset/versioned"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+)
+
+func ConvertKubeconfigToCluster(name string, cfg *rest.Config) (*clusterv1beta1.Cluster, error) {
+	cluster := clusterv1beta1.Cluster{}
+	cluster.Name = name
+	access := clusterv1beta1.ClusterAccess{}
+	if cfg.Insecure {
+		access.CABundle = cfg.CAData
+	} else {
+		access.Insecure = &cfg.Insecure
+	}
+	credential := &clusterv1beta1.ClusterAccessCredential{}
+	if cfg.KeyData != nil && cfg.CertData != nil {
+		credential.Type = clusterv1beta1.CredentialTypeX509Certificate
+		credential.X509 = &clusterv1beta1.X509{
+			Certificate: cfg.CertData,
+			PrivateKey:  cfg.KeyData,
+		}
+	} else if cfg.BearerToken != "" {
+		credential.Type = clusterv1beta1.CredentialTypeServiceAccountToken
+		credential.ServiceAccountToken = cfg.BearerToken
+	} else {
+		return nil, fmt.Errorf("failed to parse credential from kubeconfig")
+	}
+	access.Credential = credential
+	cluster.Spec.Access = access
+	return &cluster, nil
+}
+
+func ProbeWithHealthz(cfg *rest.Config) error {
+	client, err := kubernetes.NewForConfig(cfg)
+	if err != nil {
+		return err
+	}
+	var statusCode int
+	if err := client.RESTClient().
+		Get().
+		AbsPath("/healthz").
+		Do(context.TODO()).
+		StatusCode(&statusCode).
+		Error(); err != nil {
+		return err
+	}
+	if statusCode != 200 {
+		return fmt.Errorf("status code is %d, not 200", statusCode)
+	}
+	return nil
+}
+
+func CountClusters(cfg *rest.Config) (int, error) {
+	client, err := versioned.NewForConfig(cfg)
+	if err != nil {
+		return 0, err
+	}
+	clusters, err := client.ClusterV1beta1().Clusters().List(context.TODO(), metav1.ListOptions{})
+	if err != nil {
+		return 0, err
+	}
+	return len(clusters.Items), nil
+}