From 03c2c0b088521c67ca9ee8cfad73cfd35bedfb3f Mon Sep 17 00:00:00 2001 From: fukua95 Date: Tue, 20 May 2025 19:11:53 +0800 Subject: [PATCH] chore: remove unused param (#3384) Signed-off-by: fukua95 --- osscluster.go | 4 ++-- ring.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/osscluster.go b/osscluster.go index 39871b21..2365f771 100644 --- a/osscluster.go +++ b/osscluster.go @@ -1498,7 +1498,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err return err } - cmdsMap := c.mapCmdsBySlot(ctx, cmds) + cmdsMap := c.mapCmdsBySlot(cmds) for slot, cmds := range cmdsMap { node, err := state.slotMasterNode(slot) if err != nil { @@ -1537,7 +1537,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err return cmdsFirstErr(cmds) } -func (c *ClusterClient) mapCmdsBySlot(ctx context.Context, cmds []Cmder) map[int][]Cmder { +func (c *ClusterClient) mapCmdsBySlot(cmds []Cmder) map[int][]Cmder { cmdsMap := make(map[int][]Cmder) for _, cmd := range cmds { slot := c.cmdSlot(cmd) diff --git a/ring.go b/ring.go index ab3d0626..fe8a6dc4 100644 --- a/ring.go +++ b/ring.go @@ -702,7 +702,7 @@ func (c *Ring) cmdsInfo(ctx context.Context) (map[string]*CommandInfo, error) { return nil, firstErr } -func (c *Ring) cmdShard(ctx context.Context, cmd Cmder) (*ringShard, error) { +func (c *Ring) cmdShard(cmd Cmder) (*ringShard, error) { pos := cmdFirstKeyPos(cmd) if pos == 0 { return c.sharding.Random() @@ -720,7 +720,7 @@ func (c *Ring) process(ctx context.Context, cmd Cmder) error { } } - shard, err := c.cmdShard(ctx, cmd) + shard, err := c.cmdShard(cmd) if err != nil { return err }