remove_command.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. package server
  2. import (
  3. "encoding/binary"
  4. "os"
  5. "github.com/coreos/etcd/log"
  6. "github.com/coreos/raft"
  7. )
  8. func init() {
  9. raft.RegisterCommand(&RemoveCommand{})
  10. }
  11. // The RemoveCommand removes a server from the cluster.
  12. type RemoveCommand struct {
  13. Name string `json:"name"`
  14. }
  15. // The name of the remove command in the log
  16. func (c *RemoveCommand) CommandName() string {
  17. return "etcd:remove"
  18. }
  19. // Remove a server from the cluster
  20. func (c *RemoveCommand) Apply(server raft.Server) (interface{}, error) {
  21. ps, _ := server.Context().(*PeerServer)
  22. // Remove node from the shared registry.
  23. err := ps.registry.Unregister(c.Name)
  24. // Delete from stats
  25. delete(ps.followersStats.Followers, c.Name)
  26. if err != nil {
  27. log.Debugf("Error while unregistering: %s (%v)", c.Name, err)
  28. return []byte{0}, err
  29. }
  30. // Remove peer in raft
  31. err = server.RemovePeer(c.Name)
  32. if err != nil {
  33. log.Debugf("Unable to remove peer: %s (%v)", c.Name, err)
  34. return []byte{0}, err
  35. }
  36. if c.Name == server.Name() {
  37. // the removed node is this node
  38. // if the node is not replaying the previous logs
  39. // and the node has sent out a join request in this
  40. // start. It is sure that this node received a new remove
  41. // command and need to be removed
  42. if server.CommitIndex() > ps.joinIndex && ps.joinIndex != 0 {
  43. log.Debugf("server [%s] is removed", server.Name())
  44. os.Exit(0)
  45. } else {
  46. // else ignore remove
  47. log.Debugf("ignore previous remove command.")
  48. }
  49. }
  50. b := make([]byte, 8)
  51. binary.PutUvarint(b, server.CommitIndex())
  52. return b, err
  53. }