scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-09 14:41:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Make it work if the etcd is empty

Browse source
This commit is contained in:
Cody Soyland 2014-04-07 12:44:41 -05:00
parent 2c0b795b12
commit ff15b64e9f
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)