summaryrefslogtreecommitdiff
path: root/edgemesh
diff options
context:
space:
mode:
authorzhangjie <iamkadisi@163.com>2020-01-15 16:23:50 +0800
committerzhangjie <iamkadisi@163.com>2020-01-19 17:29:41 +0800
commita408ab19b5dc2dc0cab1d15f8da0e7b7986e0906 (patch)
treed5cac7d17b278d20a498ad5f5d3487bf11ddab74 /edgemesh
parentdelete edge/pkg/common/config package (diff)
downloadkubeedge-a408ab19b5dc2dc0cab1d15f8da0e7b7986e0906.tar.gz
fix:make verify,lint,edge_test error, recreate module gomock files, e2e test,edge integration
Signed-off-by: zhangjie <iamkadisi@163.com>
Diffstat (limited to 'edgemesh')
-rw-r--r--edgemesh/pkg/panel/fake.go2
-rw-r--r--edgemesh/pkg/registry/registry.go1
-rw-r--r--edgemesh/pkg/server/tcp.go4
3 files changed, 5 insertions, 2 deletions
diff --git a/edgemesh/pkg/panel/fake.go b/edgemesh/pkg/panel/fake.go
index f001e2cc0..83a1c24ea 100644
--- a/edgemesh/pkg/panel/fake.go
+++ b/edgemesh/pkg/panel/fake.go
@@ -27,6 +27,8 @@ func (fp *FakePanel) GetEgressRule() []control.EgressConfig {
return []control.EgressConfig{}
}
+// TODO Remove the init method, because it will cause invalid logs to be printed when the program is running @kadisi
+// init install Plugin
func init() {
control.InstallPlugin("fake", func(options control.Options) control.Panel {
return &FakePanel{}
diff --git a/edgemesh/pkg/registry/registry.go b/edgemesh/pkg/registry/registry.go
index 162305a28..335482946 100644
--- a/edgemesh/pkg/registry/registry.go
+++ b/edgemesh/pkg/registry/registry.go
@@ -18,6 +18,7 @@ const (
EdgeRegistry = "edge"
)
+// TODO Remove the init method, because it will cause invalid logs to be printed when the program is running @kadisi
// init initialize the plugin of edge meta registry
func init() { registry.InstallServiceDiscovery(EdgeRegistry, NewServiceDiscovery) }
diff --git a/edgemesh/pkg/server/tcp.go b/edgemesh/pkg/server/tcp.go
index 08b5b0225..0624723c2 100644
--- a/edgemesh/pkg/server/tcp.go
+++ b/edgemesh/pkg/server/tcp.go
@@ -11,7 +11,6 @@ import (
"github.com/go-chassis/go-chassis/core/invocation"
"k8s.io/klog"
- "github.com/kubeedge/beehive/pkg/common/config"
"github.com/kubeedge/kubeedge/edgemesh/pkg/resolver"
)
@@ -23,7 +22,8 @@ func StartTCP() {
}
serverIP := server.String()
- port := config.GetString("port", "8080")
+ // TODO Set as configurable @kadisi
+ port := "8080"
klog.Infof("start listening at %s:%s", serverIP, port)
listener, err := net.Listen("tcp", serverIP+":"+port)
if err != nil {