...

Source file src/edge-infra.dev/test/e2e/datasync/encryption/e2e_test.go

Documentation: edge-infra.dev/test/e2e/datasync/encryption

     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  	//go:embed testdata/tlog.json
    35  	tlog []byte
    36  
    37  	//go:embed testdata/podinfo_config_values.yaml
    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  			//bslauth.New(),
    47  			ktest.New(
    48  				ktest.WithCtrlManager(createManager),
    49  				ktest.WithEnvtestOptions(
    50  					// Do not install any CRD into cluster
    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