...
1 package encryption
2
3 import (
4 "context"
5
6 "edge-infra.dev/test/f2"
7
8 _ "embed"
9 "os"
10 "testing"
11
12 "k8s.io/apimachinery/pkg/runtime"
13
14 utilruntime "k8s.io/apimachinery/pkg/util/runtime"
15
16 clientgoscheme "k8s.io/client-go/kubernetes/scheme"
17
18 ctrl "sigs.k8s.io/controller-runtime"
19
20 dsapi "edge-infra.dev/pkg/edge/datasync/apis/v1alpha1"
21 "edge-infra.dev/pkg/k8s/runtime/controller"
22 "edge-infra.dev/pkg/lib/fog"
23 "edge-infra.dev/test/f2/x/ktest"
24 "edge-infra.dev/test/f2/x/ktest/envtest"
25 )
26
27 const (
28 DefaultChannelName = "test"
29 DefaultWorkload = "podinfo"
30 )
31
32 var (
33 f f2.Framework
34
35 tlog []byte
36
37
38 configValues []byte
39 )
40
41 func TestMain(m *testing.M) {
42 ctrl.SetLogger(fog.New().WithName("encryption_e2e_test"))
43
44 f = f2.New(context.Background(),
45 f2.WithExtensions(
46
47 ktest.New(
48 ktest.WithCtrlManager(createManager),
49 ktest.WithEnvtestOptions(
50
51 envtest.WithoutCRDs(),
52 ),
53 ktest.SkipNamespaceCreation(),
54 ),
55 ),
56 ).WithLabel("dsds", "true")
57 os.Exit(f.Run(m))
58 }
59
60 func createManager(opts ...controller.Option) (ctrl.Manager, error) {
61 mgrCfg, mgrOpts := controller.ProcessOptions(opts...)
62 mgrOpts.Scheme = createScheme()
63 return ctrl.NewManager(mgrCfg, mgrOpts)
64 }
65
66 func createScheme() *runtime.Scheme {
67 scheme := runtime.NewScheme()
68 utilruntime.Must(clientgoscheme.AddToScheme(scheme))
69 utilruntime.Must(dsapi.AddToScheme(scheme))
70 return scheme
71 }
72
View as plain text