diff --git a/src/coordinator/interface.go b/src/coordinator/interface.go index 5ec4bbce49..cac4653f24 100644 --- a/src/coordinator/interface.go +++ b/src/coordinator/interface.go @@ -38,29 +38,9 @@ type ClusterConsensus interface { SaveDbUser(user *cluster.DbUser) error ChangeDbUserPassword(db, username string, hash []byte) error ChangeDbUserPermissions(db, username, readPermissions, writePermissions string) error - - // an insert index of -1 will append to the end of the ring - AddServer(server *cluster.ClusterServer, insertIndex int) error - // only servers that are in a Potential state can be moved around in the ring - MovePotentialServer(server *cluster.ClusterServer, insertIndex int) error - /* - Activate tells the cluster to start sending writes to this node. - The node will also make requests to the other servers to backfill any - data they should have - Once the new node updates it state to "Running" the other servers will - delete all of the data that they no longer have to keep from the ring - */ - ActivateServer(server *cluster.ClusterServer) error - - // Efficient method to have a potential server take the place of a running (or downed) - // server. The replacement must have a state of "Potential" for this to work. - ReplaceServer(oldServer *cluster.ClusterServer, replacement *cluster.ClusterServer) error - AssignCoordinator(coordinator *CoordinatorImpl) error - // When a cluster is turned on for the first time. CreateRootUser() error - ForceLogCompaction() error } diff --git a/src/coordinator/raft_server.go b/src/coordinator/raft_server.go index 55910d1a28..40cfc2b500 100644 --- a/src/coordinator/raft_server.go +++ b/src/coordinator/raft_server.go @@ -268,20 +268,7 @@ func (s *RaftServer) DeleteContinuousQuery(db string, id uint32) error { return err } -func (s *RaftServer) ActivateServer(server *cluster.ClusterServer) error { - return errors.New("not implemented") -} -func (s *RaftServer) AddServer(server *cluster.ClusterServer, insertIndex int) error { - return errors.New("not implemented") -} - -func (s *RaftServer) MovePotentialServer(server *cluster.ClusterServer, insertIndex int) error { - return errors.New("not implemented") -} - -func (s *RaftServer) ReplaceServer(oldServer *cluster.ClusterServer, replacement *cluster.ClusterServer) error { - return errors.New("not implemented") } func (s *RaftServer) AssignCoordinator(coordinator *CoordinatorImpl) error { @@ -289,10 +276,6 @@ func (s *RaftServer) AssignCoordinator(coordinator *CoordinatorImpl) error { return nil } -func (s *RaftServer) connectionString() string { - return fmt.Sprintf("http://%s:%d", s.host, s.port) -} - const ( MAX_SIZE = 10 * MEGABYTE )