Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

remove some unused ClusterConsensus functions

pull/482/head
John Shahid 2014-04-29 15:16:55 -04:00
parent 08d96999a6
commit 1c09126452
2 changed files with 0 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/coordinator/interface.go
View File

@ -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
}

17
src/coordinator/raft_server.go
View File

@ -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
)