@@ -989,7 +989,7 @@ func (c *ClusterClient) Process(ctx context.Context, cmd Cmder) error {
989
989
}
990
990
991
991
func (c * ClusterClient ) process (ctx context.Context , cmd Cmder ) error {
992
- slot := c .cmdSlot (ctx , cmd )
992
+ slot := c .cmdSlot (cmd )
993
993
var node * clusterNode
994
994
var moved bool
995
995
var ask bool
@@ -1480,7 +1480,7 @@ func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmd
1480
1480
1481
1481
if c .opt .ReadOnly && c .cmdsAreReadOnly (ctx , cmds ) {
1482
1482
for _ , cmd := range cmds {
1483
- slot := c .cmdSlot (ctx , cmd )
1483
+ slot := c .cmdSlot (cmd )
1484
1484
node , err := c .slotReadOnlyNode (state , slot )
1485
1485
if err != nil {
1486
1486
return err
@@ -1491,7 +1491,7 @@ func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmd
1491
1491
}
1492
1492
1493
1493
for _ , cmd := range cmds {
1494
- slot := c .cmdSlot (ctx , cmd )
1494
+ slot := c .cmdSlot (cmd )
1495
1495
node , err := state .slotMasterNode (slot )
1496
1496
if err != nil {
1497
1497
return err
@@ -1635,7 +1635,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
1635
1635
func (c * ClusterClient ) mapCmdsBySlot (ctx context.Context , cmds []Cmder ) map [int ][]Cmder {
1636
1636
cmdsMap := make (map [int ][]Cmder )
1637
1637
for _ , cmd := range cmds {
1638
- slot := c .cmdSlot (ctx , cmd )
1638
+ slot := c .cmdSlot (cmd )
1639
1639
cmdsMap [slot ] = append (cmdsMap [slot ], cmd )
1640
1640
}
1641
1641
return cmdsMap
@@ -1664,7 +1664,7 @@ func (c *ClusterClient) processTxPipelineNode(
1664
1664
}
1665
1665
1666
1666
func (c * ClusterClient ) processTxPipelineNodeConn (
1667
- ctx context.Context , node * clusterNode , cn * pool.Conn , cmds []Cmder , failedCmds * cmdsMap ,
1667
+ ctx context.Context , _ * clusterNode , cn * pool.Conn , cmds []Cmder , failedCmds * cmdsMap ,
1668
1668
) error {
1669
1669
if err := cn .WithWriter (c .context (ctx ), c .opt .WriteTimeout , func (wr * proto.Writer ) error {
1670
1670
return writeCmds (wr , cmds )
@@ -1934,7 +1934,7 @@ func (c *ClusterClient) cmdInfo(ctx context.Context, name string) *CommandInfo {
1934
1934
return info
1935
1935
}
1936
1936
1937
- func (c * ClusterClient ) cmdSlot (ctx context. Context , cmd Cmder ) int {
1937
+ func (c * ClusterClient ) cmdSlot (cmd Cmder ) int {
1938
1938
args := cmd .Args ()
1939
1939
if args [0 ] == "cluster" && (args [1 ] == "getkeysinslot" || args [1 ] == "countkeysinslot" ) {
1940
1940
return args [2 ].(int )
0 commit comments