address feedback

This commit is contained in:
Matt Jaffee 2018-07-05 17:38:49 -05:00
parent 27c071ac85
commit e33682cfd2
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
2 changed files with 3 additions and 4 deletions

View file

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

View file

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