This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 4a74932 Fix: EvnetTypeUpdate -> EventTypeUpdate
4a74932 is described below
commit 4a749324e06c988b31f239245386dae2be8833a6
Author: AlexStocks <alexsto...@foxmail.com>
AuthorDate: Thu Aug 29 13:09:18 2019 +0800
Fix: EvnetTypeUpdate -> EventTypeUpdate
---
.../zookeeper/dubbo/with-configcenter-go-client/app/client.go | 2 +-
.../zookeeper/dubbo/with-configcenter-go-server/app/server.go | 2 +-
.../zookeeper/jsonrpc/with-configcenter-go-client/app/client.go | 2 +-
.../zookeeper/jsonrpc/with-configcenter-go-server/app/server.go | 2 +-
examples/general/dubbo/go-client/app/client.go | 2 +-
examples/general/dubbo/go-server/app/server.go | 2 +-
examples/general/jsonrpc/go-client/app/client.go | 2 +-
examples/general/jsonrpc/go-server/app/server.go | 2 +-
examples/helloworld/dubbo/go-server/app/server.go | 2 +-
remoting/listener.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
11 files changed, 11 insertions(+), 11 deletions(-)
diff --git
a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
index d27af7a..44ffbd9 100644
---
a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
+++
b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-client/app/client.go
@@ -135,7 +135,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go
time.AfterFunc(time.Duration(survivalTimeout)*time.Second, func() {
+
time.AfterFunc(time.Duration(survivalTimeout)*time.Second, func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git
a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
index cd98299..04c614d 100644
---
a/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
+++
b/examples/configcenter/zookeeper/dubbo/with-configcenter-go-server/app/server.go
@@ -73,7 +73,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go
time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)),
func() {
+
time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)),
func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git
a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
index 5b16347..db76d93 100644
---
a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
+++
b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-client/app/client.go
@@ -120,7 +120,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go
time.AfterFunc(time.Duration(survivalTimeout)*time.Second, func() {
+
time.AfterFunc(time.Duration(survivalTimeout)*time.Second, func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git
a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
index 0a0e729..23cfd41 100644
---
a/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
+++
b/examples/configcenter/zookeeper/jsonrpc/with-configcenter-go-server/app/server.go
@@ -62,7 +62,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go
time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)),
func() {
+
time.AfterFunc(time.Duration(float64(survivalTimeout)*float64(time.Second)),
func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/examples/general/dubbo/go-client/app/client.go
b/examples/general/dubbo/go-client/app/client.go
index e839b0b..60adad3 100644
--- a/examples/general/dubbo/go-client/app/client.go
+++ b/examples/general/dubbo/go-client/app/client.go
@@ -78,7 +78,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go time.AfterFunc(time.Duration(survivalTimeout),
func() {
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/examples/general/dubbo/go-server/app/server.go
b/examples/general/dubbo/go-server/app/server.go
index ac92b87..0ffd630 100644
--- a/examples/general/dubbo/go-server/app/server.go
+++ b/examples/general/dubbo/go-server/app/server.go
@@ -74,7 +74,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go time.AfterFunc(time.Duration(survivalTimeout),
func() {
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/examples/general/jsonrpc/go-client/app/client.go
b/examples/general/jsonrpc/go-client/app/client.go
index abbe586..c281794 100644
--- a/examples/general/jsonrpc/go-client/app/client.go
+++ b/examples/general/jsonrpc/go-client/app/client.go
@@ -73,7 +73,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go time.AfterFunc(time.Duration(survivalTimeout),
func() {
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/examples/general/jsonrpc/go-server/app/server.go
b/examples/general/jsonrpc/go-server/app/server.go
index e36b6ef..de4aaed 100644
--- a/examples/general/jsonrpc/go-server/app/server.go
+++ b/examples/general/jsonrpc/go-server/app/server.go
@@ -64,7 +64,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go time.AfterFunc(time.Duration(survivalTimeout),
func() {
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/examples/helloworld/dubbo/go-server/app/server.go
b/examples/helloworld/dubbo/go-server/app/server.go
index f02a6ba..dc3a40f 100644
--- a/examples/helloworld/dubbo/go-server/app/server.go
+++ b/examples/helloworld/dubbo/go-server/app/server.go
@@ -64,7 +64,7 @@ func initSignal() {
case syscall.SIGHUP:
// reload()
default:
- go time.AfterFunc(time.Duration(survivalTimeout),
func() {
+ time.AfterFunc(time.Duration(survivalTimeout), func() {
logger.Warnf("app exit now by force...")
os.Exit(1)
})
diff --git a/remoting/listener.go b/remoting/listener.go
index da30f69..866c850 100644
--- a/remoting/listener.go
+++ b/remoting/listener.go
@@ -46,7 +46,7 @@ type EventType int
const (
EventTypeAdd = iota
EventTypeDel
- EvnetTypeUpdate
+ EventTypeUpdate
)
var serviceEventTypeStrings = [...]string{
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index fda265c..eaf941b 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -70,7 +70,7 @@ func (l *ZkEventListener) ListenServiceNodeEvent(zkPath
string, listener ...remo
logger.Warnf("zk.ExistW(key{%s}) =
event{EventNodeDataChanged}", zkPath)
if len(listener) > 0 {
content, _, _ :=
l.client.Conn.Get(zkEvent.Path)
-
listener[0].DataChange(remoting.Event{Path: zkEvent.Path, Action:
remoting.EvnetTypeUpdate, Content: string(content)})
+
listener[0].DataChange(remoting.Event{Path: zkEvent.Path, Action:
remoting.EventTypeUpdate, Content: string(content)})
}
case zk.EventNodeCreated:
