diff options
| author | fisherxu <xufei40@huawei.com> | 2021-05-31 16:00:41 +0800 |
|---|---|---|
| committer | fisherxu <xufei40@huawei.com> | 2021-05-31 19:59:09 +0800 |
| commit | 320132bf8349799a8c142004ce189695c358f52a (patch) | |
| tree | cedf4b46c395a953c99bb9be3c3d158bc9f55d86 /tests | |
| parent | remove leaderelection related code (diff) | |
| download | kubeedge-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.go | 43 |
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: |
