@@ -981,7 +981,7 @@ func (c *ClusterClient) Process(ctx context.Context, cmd Cmder) error {
981
981
}
982
982
983
983
func (c * ClusterClient ) process (ctx context.Context , cmd Cmder ) error {
984
- slot := c .cmdSlot (ctx , cmd )
984
+ slot := c .cmdSlot (cmd )
985
985
var node * clusterNode
986
986
var moved bool
987
987
var ask bool
@@ -1329,7 +1329,7 @@ func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmd
1329
1329
1330
1330
if c .opt .ReadOnly && c .cmdsAreReadOnly (ctx , cmds ) {
1331
1331
for _ , cmd := range cmds {
1332
- slot := c .cmdSlot (ctx , cmd )
1332
+ slot := c .cmdSlot (cmd )
1333
1333
node , err := c .slotReadOnlyNode (state , slot )
1334
1334
if err != nil {
1335
1335
return err
@@ -1340,7 +1340,7 @@ func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmd
1340
1340
}
1341
1341
1342
1342
for _ , cmd := range cmds {
1343
- slot := c .cmdSlot (ctx , cmd )
1343
+ slot := c .cmdSlot (cmd )
1344
1344
node , err := state .slotMasterNode (slot )
1345
1345
if err != nil {
1346
1346
return err
@@ -1540,7 +1540,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
1540
1540
func (c * ClusterClient ) mapCmdsBySlot (ctx context.Context , cmds []Cmder ) map [int ][]Cmder {
1541
1541
cmdsMap := make (map [int ][]Cmder )
1542
1542
for _ , cmd := range cmds {
1543
- slot := c .cmdSlot (ctx , cmd )
1543
+ slot := c .cmdSlot (cmd )
1544
1544
cmdsMap [slot ] = append (cmdsMap [slot ], cmd )
1545
1545
}
1546
1546
return cmdsMap
@@ -1569,7 +1569,7 @@ func (c *ClusterClient) processTxPipelineNode(
1569
1569
}
1570
1570
1571
1571
func (c * ClusterClient ) processTxPipelineNodeConn (
1572
- ctx context.Context , node * clusterNode , cn * pool.Conn , cmds []Cmder , failedCmds * cmdsMap ,
1572
+ ctx context.Context , _ * clusterNode , cn * pool.Conn , cmds []Cmder , failedCmds * cmdsMap ,
1573
1573
) error {
1574
1574
if err := cn .WithWriter (c .context (ctx ), c .opt .WriteTimeout , func (wr * proto.Writer ) error {
1575
1575
return writeCmds (wr , cmds )
@@ -1858,7 +1858,7 @@ func (c *ClusterClient) cmdInfo(ctx context.Context, name string) *CommandInfo {
1858
1858
return info
1859
1859
}
1860
1860
1861
- func (c * ClusterClient ) cmdSlot (ctx context. Context , cmd Cmder ) int {
1861
+ func (c * ClusterClient ) cmdSlot (cmd Cmder ) int {
1862
1862
args := cmd .Args ()
1863
1863
if args [0 ] == "cluster" && (args [1 ] == "getkeysinslot" || args [1 ] == "countkeysinslot" ) {
1864
1864
return args [2 ].(int )
0 commit comments