diff --git a/cluster.go b/cluster.go index 89f1e9a..767df5f 100644 --- a/cluster.go +++ b/cluster.go @@ -491,13 +491,14 @@ func (c *clusterState) slotNodes(slot int) []*clusterNode { //------------------------------------------------------------------------------ type clusterStateHolder struct { - load func() (*clusterState, error) - reloading uint32 // atomic + load func() (*clusterState, error) state atomic.Value lastErrMu sync.RWMutex lastErr error + + reloading uint32 // atomic } func newClusterStateHolder(fn func() (*clusterState, error)) *clusterStateHolder {