...
1
16
17 package client_test
18
19 import (
20 "testing"
21
22 . "github.com/onsi/ginkgo/v2"
23 . "github.com/onsi/gomega"
24 "k8s.io/client-go/kubernetes"
25 "k8s.io/client-go/kubernetes/scheme"
26 "k8s.io/client-go/rest"
27 "sigs.k8s.io/controller-runtime/examples/crd/pkg"
28 "sigs.k8s.io/controller-runtime/pkg/envtest"
29
30 logf "sigs.k8s.io/controller-runtime/pkg/log"
31 "sigs.k8s.io/controller-runtime/pkg/log/zap"
32 )
33
34 func TestClient(t *testing.T) {
35 RegisterFailHandler(Fail)
36 RunSpecs(t, "Client Suite")
37 }
38
39 var testenv *envtest.Environment
40 var cfg *rest.Config
41 var clientset *kubernetes.Clientset
42
43 var _ = BeforeSuite(func() {
44 logf.SetLogger(zap.New(zap.WriteTo(GinkgoWriter), zap.UseDevMode(true)))
45
46 testenv = &envtest.Environment{CRDDirectoryPaths: []string{"./testdata"}}
47
48 var err error
49 cfg, err = testenv.Start()
50 Expect(err).NotTo(HaveOccurred())
51
52 clientset, err = kubernetes.NewForConfig(cfg)
53 Expect(err).NotTo(HaveOccurred())
54
55 Expect(pkg.AddToScheme(scheme.Scheme)).NotTo(HaveOccurred())
56 })
57
58 var _ = AfterSuite(func() {
59 Expect(testenv.Stop()).To(Succeed())
60 })
61
View as plain text