clients.go

package k8sclienttest

import (
	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/client-go/dynamic"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/kubernetes/scheme"
	"k8s.io/client-go/rest"
	"sigs.k8s.io/controller-runtime/pkg/client"

	"github.com/LeXFReeMan/k8sclient/v7/pkg/k8scrdclient"
)

type ClientsConfig struct {
	CRDClient  k8scrdclient.Interface
	CtrlClient client.Client
	DynClient  dynamic.Interface
	ExtClient  apiextensionsclient.Interface
	K8sClient  kubernetes.Interface
	RestClient rest.Interface
	RestConfig *rest.Config
}

type Clients struct {
	crdClient  k8scrdclient.Interface
	ctrlClient client.Client
	dynClient  dynamic.Interface
	extClient  apiextensionsclient.Interface
	k8sClient  kubernetes.Interface
	restClient rest.Interface
	restConfig *rest.Config
}

func NewClients(config ClientsConfig) *Clients {
	c := &Clients{
		crdClient:  config.CRDClient,
		ctrlClient: config.CtrlClient,
		dynClient:  config.DynClient,
		extClient:  config.ExtClient,
		k8sClient:  config.K8sClient,
		restClient: config.RestClient,
		restConfig: config.RestConfig,
	}

	return c
}

func (c *Clients) CRDClient() k8scrdclient.Interface {
	return c.crdClient
}

func (c *Clients) CtrlClient() client.Client {
	return c.ctrlClient
}

func (c *Clients) DynClient() dynamic.Interface {
	return c.dynClient
}

func (c *Clients) ExtClient() apiextensionsclient.Interface {
	return c.extClient
}

func (c *Clients) K8sClient() kubernetes.Interface {
	return c.k8sClient
}

func (c *Clients) RESTClient() rest.Interface {
	return c.restClient
}

func (c *Clients) RESTConfig() *rest.Config {
	return rest.CopyConfig(c.restConfig)
}

func (c *Clients) Scheme() *runtime.Scheme {
	return scheme.Scheme
}