Update local metadata from etcd watcher.

This commit is contained in:
Cody Soyland 2013-12-11 10:45:37 -06:00
parent 7d31f48732
commit f7b5550315

View file

@ -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)
}
}
}()
}