e2e_test.go

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

     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  	//go:embed testdata/tlog.json
    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  			// Include ktest extension for access to a k8s cluster
    38  			ktest.New(
    39  				ktest.WithCtrlManager(createManager),
    40  				ktest.WithEnvtestOptions(
    41  					// Do not install any CRD into cluster
    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