clusterSlots.go

	var c radix.Client
	var raw resp2.RawMessage
	err = conn.Do(radix.Cmd(&raw, "CLUSTER", "SLOTS"))
	if err == nil {
		var ct radix.ClusterTopo
		var rerr resp2.Error
		if ct.UnmarshalRESP(bufio.NewReaderSize(bytes.NewReader(raw), len(raw))) == nil {
			c, err = radix.NewCluster([]string{ar.Addr},
				radix.ClusterPoolFunc(df),
			)
		} else if uerr := rerr.UnmarshalRESP(bufio.NewReaderSize(bytes.NewReader(raw), len(raw))); uerr == nil && strings.Contains(rerr.Error(), "cluster support disabled") {
			r.addr = ar.Addr
			c, err = df("tcp", ar.Addr)
		} else {
			err = errors.New("unsupported response from CLUSTER SLOTS")
		}
	}