...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15 package testmain_test
16
17 import (
18 "testing"
19
20 testmain "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/test/main"
21 "k8s.io/apimachinery/pkg/version"
22 "k8s.io/client-go/kubernetes"
23 "k8s.io/client-go/rest"
24 "sigs.k8s.io/controller-runtime/pkg/manager"
25 )
26
27 var (
28 mgr manager.Manager
29 )
30
31
32
33
34 func TestKubeAPIServerVersion(t *testing.T) {
35 expectedVersion := "v1.21.0"
36 v, err := getKubernetesVersion(mgr.GetConfig())
37 if err != nil {
38 t.Fatalf("error retrieving the Kubernetes API Server version")
39 }
40 if v.String() != expectedVersion {
41 t.Fatalf("got the Kubernetes API Server version %v, expect to have %v", v, expectedVersion)
42 }
43 }
44
45
46
47 func getKubernetesVersion(clientConfig *rest.Config) (*version.Info, error) {
48 clientGoClient := kubernetes.NewForConfigOrDie(mgr.GetConfig())
49 version, err := clientGoClient.ServerVersion()
50 return version, err
51 }
52
53 func TestMain(m *testing.M) {
54 testmain.TestMainForUnitTests(m, &mgr)
55 }
56
View as plain text