summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorfisherxu <xufei40@huawei.com>2021-05-31 16:00:41 +0800
committerfisherxu <xufei40@huawei.com>2021-05-31 19:59:09 +0800
commit320132bf8349799a8c142004ce189695c358f52a (patch)
treecedf4b46c395a953c99bb9be3c3d158bc9f55d86 /tests
parentremove leaderelection related code (diff)
downloadkubeedge-320132bf8349799a8c142004ce189695c358f52a.tar.gz
negotiate tunnel port for multi cloudcore instaces
Signed-off-by: fisherxu <xufei40@huawei.com>
Diffstat (limited to 'tests')
-rw-r--r--tests/integration/framework/util.go43
1 files changed, 0 insertions, 43 deletions
diff --git a/tests/integration/framework/util.go b/tests/integration/framework/util.go
index c906064f5..6bb583800 100644
--- a/tests/integration/framework/util.go
+++ b/tests/integration/framework/util.go
@@ -3,53 +3,10 @@ package framework
import (
"k8s.io/klog/v2"
- "github.com/kubeedge/kubeedge/cloud/pkg/cloudhub"
- "github.com/kubeedge/kubeedge/cloud/pkg/cloudstream"
- "github.com/kubeedge/kubeedge/cloud/pkg/devicecontroller"
- "github.com/kubeedge/kubeedge/cloud/pkg/dynamiccontroller"
- "github.com/kubeedge/kubeedge/cloud/pkg/edgecontroller"
- "github.com/kubeedge/kubeedge/cloud/pkg/router"
- "github.com/kubeedge/kubeedge/cloud/pkg/synccontroller"
- "github.com/kubeedge/kubeedge/edge/pkg/common/dbm"
- "github.com/kubeedge/kubeedge/edge/pkg/devicetwin"
- "github.com/kubeedge/kubeedge/edge/pkg/edgehub"
- "github.com/kubeedge/kubeedge/edge/pkg/edgestream"
- "github.com/kubeedge/kubeedge/edge/pkg/eventbus"
- "github.com/kubeedge/kubeedge/edge/pkg/metamanager"
- "github.com/kubeedge/kubeedge/edge/pkg/servicebus"
- "github.com/kubeedge/kubeedge/edge/test"
cloudconfig "github.com/kubeedge/kubeedge/pkg/apis/componentconfig/cloudcore/v1alpha1"
edgeconfig "github.com/kubeedge/kubeedge/pkg/apis/componentconfig/edgecore/v1alpha1"
)
-// registerModules register all the modules
-func registerModules(i interface{}) {
- switch c := i.(type) {
- case *cloudconfig.CloudCoreConfig:
- cloudhub.Register(c.Modules.CloudHub)
- edgecontroller.Register(c.Modules.EdgeController)
- devicecontroller.Register(c.Modules.DeviceController)
- synccontroller.Register(c.Modules.SyncController)
- cloudstream.Register(c.Modules.CloudStream)
- router.Register(c.Modules.Router)
- dynamiccontroller.Register(c.Modules.DynamicController)
- case *edgeconfig.EdgeCoreConfig:
- devicetwin.Register(c.Modules.DeviceTwin, c.Modules.Edged.HostnameOverride)
- //edged.Register(c.Modules.Edged)
- edgehub.Register(c.Modules.EdgeHub, c.Modules.Edged.HostnameOverride)
- eventbus.Register(c.Modules.EventBus, c.Modules.Edged.HostnameOverride)
- //edgemesh.Register(c.Modules.EdgeMesh)
- metamanager.Register(c.Modules.MetaManager)
- servicebus.Register(c.Modules.ServiceBus)
- edgestream.Register(c.Modules.EdgeStream, c.Modules.Edged.HostnameOverride, c.Modules.Edged.NodeIP)
- test.Register(c.Modules.DBTest)
- // Note: Need to put it to the end, and wait for all models to register before executing
- dbm.InitDBConfig(c.DataBase.DriverName, c.DataBase.AliasName, c.DataBase.DataSource)
- default:
- klog.Error("unsupport config type!")
- }
-}
-
func DisableAllModules(i interface{}) {
switch config := i.(type) {
case *cloudconfig.CloudCoreConfig: