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

ok

Browse source
This commit is contained in:
Todd Gruben 2014-06-19 13:23:39 -05:00
parent 784acc982f
commit 27ab4f7c0b
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
core/etcd.go
View file

@ -59,6 +59,8 @@ func (self *TopologyMapper) Run() {
switch resp.Action {
case "set":
self.handlenode(resp.Node)
case "delete":
self.remove_fragment(resp.Node)
}
// TODO: handle deletes
}
@ -227,6 +229,19 @@ func (self *TopologyMapper) handlenode(node *etcd.Node) error {
}
return err
}
func (self *TopologyMapper) remove_fragment(node *etcd.Node) error {
log.Println(" hot remove_fragment (Not Supported yet):", node)
/*
key := node.Key[len(self.namespace)+1:]
bits := strings.Split(key, "/")
process_uuid, err = util.ParseGUID(node.Value)
if self.service.Id.String() == process_uuid.String() {
fragment_id = util.Hex_to_SUUID(bits[7])
self.service.Index.RemoveFragment(fragment_id)
}
*/
return nil
}
func flatten(node *etcd.Node) []*etcd.Node {
nodes := []*etcd.Node{node}