Skip to content
Snippets Groups Projects
Unverified Commit 014d1bc6 authored by vito.he's avatar vito.he Committed by GitHub
Browse files

Merge pull request #177 from dubbo-x/develop

fix typo
parents 593703d2 d733321a
No related branches found
No related tags found
No related merge requests found
......@@ -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})
}
}
}
......
......@@ -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),
})
}
......
......@@ -46,7 +46,7 @@ type EventType int
const (
EventTypeAdd = iota
EventTypeDel
EvnetTypeUpdate
EventTypeUpdate
)
var serviceEventTypeStrings = [...]string{
......
......@@ -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)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment