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

Unexport NodeStateReady

Browse source
This commit is contained in:
Cody Soyland 2018-07-05 21:49:56 -05:00
parent 9222ef0df7
commit 3e91a0d32c
3 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
cluster.go
View file

@ -45,7 +45,7 @@ const (
ClusterStateResizing = "RESIZING"
// NodeState represents the state of a node during startup.
NodeStateReady = "READY"
nodeStateReady = "READY"
// resizeJob states.
resizeJobStateRunning = "RUNNING"
@ -903,7 +903,7 @@ func (c *cluster) allNodesReady() bool {
return true
}
for _, uri := range c.Topology.NodeIDs {
if c.Topology.nodeStates[uri] != NodeStateReady {
if c.Topology.nodeStates[uri] != nodeStateReady {
return false
}
}

2
server.go
View file

@ -337,7 +337,7 @@ func (s *Server) Open() error {
if err := s.holder.Open(); err != nil {
return fmt.Errorf("opening Holder: %v", err)
}
if err := s.cluster.setNodeState(NodeStateReady); err != nil {
if err := s.cluster.setNodeState(nodeStateReady); err != nil {
return fmt.Errorf("setting nodeState: %v", err)
}

2
utils_internal_test.go
View file

@ -277,7 +277,7 @@ func (t *ClusterCluster) Open() error {
if err := c.holder.Open(); err != nil {
return err
}
if err := c.setNodeState(NodeStateReady); err != nil {
if err := c.setNodeState(nodeStateReady); err != nil {
return err
}
}