linkerd2/controller/k8s/clientset.go

28 lines
670 B
Go

package k8s
import (
spclient "github.com/linkerd/linkerd2/controller/gen/client/clientset/versioned"
"github.com/linkerd/linkerd2/pkg/k8s"
"k8s.io/client-go/kubernetes"
// Load all the auth plugins for the cloud providers.
_ "k8s.io/client-go/plugin/pkg/client/auth"
)
func NewClientSet(kubeConfig string) (*kubernetes.Clientset, error) {
config, err := k8s.GetConfig(kubeConfig, "")
if err != nil {
return nil, err
}
return kubernetes.NewForConfig(config)
}
func NewSpClientSet(kubeConfig string) (*spclient.Clientset, error) {
config, err := k8s.GetConfig(kubeConfig, "")
if err != nil {
return nil, err
}
return spclient.NewForConfig(config)
}