This is an automated email from the ASF dual-hosted git repository.
xinminghe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new d733321 fix typo
new 014d1bc Merge pull request #177 from dubbo-x/develop
d733321 is described below
commit d733321aeeeefa61b777ee27e3bf97550e85b3e4
Author: 高辛格 <xg....@tianrang-inc.com>
AuthorDate: Wed Aug 28 16:37:21 2019 +0800
fix typo
---
registry/nacos/listener.go | 2 +-
remoting/etcdv3/listener.go | 2 +-
remoting/listener.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/registry/nacos/listener.go b/registry/nacos/listener.go
index c42abd0..0cb48e0 100644
--- a/registry/nacos/listener.go
+++ b/registry/nacos/listener.go
@@ -147,7 +147,7 @@ func (nl *nacosListener) Callback(services
[]model.SubscribeService, err error)
for i := range updateInstances {
newUrl := generateUrl(updateInstances[i])
if newUrl != nil {
- nl.process(&remoting.ConfigChangeEvent{Value: *newUrl,
ConfigType: remoting.EvnetTypeUpdate})
+ nl.process(&remoting.ConfigChangeEvent{Value: *newUrl,
ConfigType: remoting.EventTypeUpdate})
}
}
}
diff --git a/remoting/etcdv3/listener.go b/remoting/etcdv3/listener.go
index 59273af..f540191 100644
--- a/remoting/etcdv3/listener.go
+++ b/remoting/etcdv3/listener.go
@@ -100,7 +100,7 @@ func (l *EventListener) handleEvents(event *clientv3.Event,
listeners ...remotin
logger.Infof("etcd get event (key{%s}) =
event{EventNodeDataChanged}", event.Kv.Key)
listener.DataChange(remoting.Event{
Path: string(event.Kv.Key),
- Action: remoting.EvnetTypeUpdate,
+ Action: remoting.EventTypeUpdate,
Content: string(event.Kv.Value),
})
}
diff --git a/remoting/listener.go b/remoting/listener.go
index fd566f3..b94ba26 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 12f7d1f..9521ea7 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -72,7 +72,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:
logger.Warnf("zk.ExistW(key{%s}) =
event{EventNodeCreated}", zkPath)
