scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'master' of ops:nuevo-pilosa

Browse source
This commit is contained in:
Todd Gruben 2014-04-07 13:07:44 -05:00
commit 7cc7159165
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
core/etcd.go
View file

@ -22,9 +22,18 @@ type TopologyMapper struct {
func (self *TopologyMapper) Run() {
log.Println(self.namespace + "/db")
resp, err := self.service.Etcd.Get(self.namespace+"/db", false, true)
db_path := self.namespace + "/db"
resp, err := self.service.Etcd.Get(db_path, false, true)
if err != nil {
log.Fatal(err)
ee, ok := err.(*etcd.EtcdError)
if ok && ee.ErrorCode == 100 { // node does not exist
resp, err = self.service.Etcd.CreateDir(db_path, 0)
if err != nil {
log.Fatal(err)
}
} else {
log.Fatal(err)
}
}
for _, node := range flatten(resp.Node) {
err := self.handlenode(node)