diff --git a/cluster.go b/cluster.go index 6d8cf38b4..f61173c3b 100644 --- a/cluster.go +++ b/cluster.go @@ -459,7 +459,7 @@ func (c *cluster) receiveNodeState(nodeID string, state string) error { return nil } -// Status returns the the cluster's status including what nodes it contains, it's ID, and current state. +// Status returns the the cluster's status including what nodes it contains, its ID, and current state. func (c *cluster) Status() *ClusterStatus { return &ClusterStatus{ ClusterID: c.id, @@ -1764,7 +1764,7 @@ type ResizeSource struct { Shard uint64 `protobuf:"varint,5,opt,name=Shard,proto3" json:"Shard,omitempty"` } -// Schema is a schema +// Schema contains information about indexes and their configuration. type Schema struct { Indexes []*IndexInfo } diff --git a/utils_internal_test.go b/utils_internal_test.go index e0a42bdc1..df1b7d2e0 100644 --- a/utils_internal_test.go +++ b/utils_internal_test.go @@ -364,8 +364,7 @@ func (t *ClusterCluster) FollowResizeInstruction(instr *ResizeInstruction) error } for _, src := range instr.Sources { - srcNode := src.Node - srcCluster := t.clusterByID(srcNode.ID) + srcCluster := t.clusterByID(src.Node.ID) srcFragment := srcCluster.holder.fragment(src.Index, src.Field, src.View, src.Shard) destFragment := destCluster.holder.fragment(src.Index, src.Field, src.View, src.Shard)