Method pickArbitraryNode

osscluster_router.go:491–501

pickArbitraryNode selects a master or slave shard using the configured ShardPicker

(ctx context.Context)

// pickArbitraryNode selects a master or slave shard using the configured ShardPicker
func (c *ClusterClient) pickArbitraryNode(ctx context.Context) *clusterNode {
	state, err := c.state.Get(ctx)
	if err != nil || len(state.Masters) == 0 {
		return nil
	}

	allNodes := append(state.Masters, state.Slaves...)

	idx := c.opt.ShardPicker.Next(len(allNodes))
	return allNodes[idx]
}

// hasKeys checks if a command operates on keys
func (c *ClusterClient) hasKeys(cmd Cmder) bool {