diff options
| author | zhangjie <iamkadisi@163.com> | 2020-01-15 16:23:50 +0800 |
|---|---|---|
| committer | zhangjie <iamkadisi@163.com> | 2020-01-19 17:29:41 +0800 |
| commit | a408ab19b5dc2dc0cab1d15f8da0e7b7986e0906 (patch) | |
| tree | d5cac7d17b278d20a498ad5f5d3487bf11ddab74 /edgemesh | |
| parent | delete edge/pkg/common/config package (diff) | |
| download | kubeedge-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.go | 2 | ||||
| -rw-r--r-- | edgemesh/pkg/registry/registry.go | 1 | ||||
| -rw-r--r-- | edgemesh/pkg/server/tcp.go | 4 |
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 { |
