Spaces:
Sleeping
Sleeping
File size: 1,072 Bytes
287a0bc |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
package utils
import (
"k8s.io/client-go/dynamic"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/kubernetes/fake"
"k8s.io/client-go/rest"
)
func GetTestKubenertesInterface() (kubernetes.Interface, error) {
clientset := fake.NewSimpleClientset()
return clientset, nil
}
func getKubernetesConfig() (*rest.Config, error) {
config, err := rest.InClusterConfig()
if err != nil {
return nil, err
}
return config, nil
}
func GetKubernetesDynamicInterface() (dynamic.Interface, error) {
clientConfig, err := getKubernetesConfig()
if err != nil {
return nil, err
}
// Create the dynamic client for the memberlist custom resource
dynamic_client, err := dynamic.NewForConfig(clientConfig)
if err != nil {
panic(err.Error())
}
return dynamic_client, nil
}
func GetKubernetesInterface() (kubernetes.Interface, error) {
config, err := getKubernetesConfig()
if err != nil {
return nil, err
}
// Create a clientset for the coordinator
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
return nil, err
}
return clientset, nil
}
|