diff --git a/cluster.go b/cluster.go index aa48ba57c..6f0a88904 100644 --- a/cluster.go +++ b/cluster.go @@ -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 } } diff --git a/server.go b/server.go index 6ee4c6c60..91c2d813a 100644 --- a/server.go +++ b/server.go @@ -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) } diff --git a/utils_internal_test.go b/utils_internal_test.go index baaac04e3..816c477ce 100644 --- a/utils_internal_test.go +++ b/utils_internal_test.go @@ -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 } }