package runtime

import (
	"log"

	"k8s.io/apimachinery/pkg/runtime"
	restclient "k8s.io/client-go/rest"
	cloudv1 "pingcap.com/cloud/v2/cluster/api/v1"
	"sigs.k8s.io/controller-runtime/pkg/client"
)

func GetCentralClient() client.Client {
	scheme := runtime.NewScheme()
	cloudv1.AddToScheme(scheme)
	config := &restclient.Config{
		Host:        "https://kube_apiserver:6443",
		BearerToken: "kube_rbac_token",
		TLSClientConfig: restclient.TLSClientConfig{
			Insecure: true,
		},
	}
	controllerClient, err := client.New(config, client.Options{Scheme: scheme})
	if err != nil {
		log.Fatal(err)
		return nil
	}
	return controllerClient
}