diff --git a/core/etcd.go b/core/etcd.go index 143b09083..054ffe96a 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -112,8 +112,11 @@ func (service *Service) MetaWatcher() { _, _ = service.Etcd.Watch(namespace + "/db", 0, true, receiver, stop) }() go func() { - for x := range receiver { - spew.Dump(x) + for resp = range receiver { + switch resp.Action { + case "set": + handlenode(resp.Node, namespace, cluster) + } } }() }