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