status-im
/
consul
mirror of https://github.com/status-im/consul.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Delete node in a transaction

This commit is contained in:
Armon Dadgar 2014-01-08 10:37:16 -08:00
parent 4ebf710394
commit 842bf62587
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
consul/state_store.go
View File

@ -280,13 +280,19 @@ func (s *StateStore) DeleteNodeService(node, id string) error {
// DeleteNode is used to delete a node and all it's services
func (s *StateStore) DeleteNode(node string) error {
if _, err := s.serviceTable.Delete("id", node); err != nil {
tx, err := s.tables.StartTxn(false)
if err != nil {
panic(fmt.Errorf("Failed to start txn: %v", err))
}
defer tx.Abort()
if _, err := s.serviceTable.DeleteTxn(tx, "id", node); err != nil {
return err
}
if _, err := s.nodeTable.Delete("id", node); err != nil {
if _, err := s.nodeTable.DeleteTxn(tx, "id", node); err != nil {
return err
}
return nil
return tx.Commit()
}
// Services is used to return all the services with a list of associated tags