diff --git a/registry/nacos/listener.go b/registry/nacos/listener.go index c42abd0bb16573da33c20c150896f85b3a7edfd0..0cb48e076452941ae0162a737b5ba1fb85f84def 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 59273af554a63e5fc907ba5a30bb1e18bb22c0f5..f5401917e208f41d3ea84e47c46f535b344e2784 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 fd566f353857943acd620af5da21e85054dff646..b94ba26980b50db99e766fcc8febb07d6b554274 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 12f7d1fa6ca2e31abdea8077d419e32d95736c6e..9521ea749027582c015ac998a6f6f68d350cc3bc 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)