From ecc985b75b692dc7881c6c47fc8ac0012e89181c Mon Sep 17 00:00:00 2001 From: Nedyalko Dyakov Date: Tue, 24 Jun 2025 09:30:25 +0300 Subject: [PATCH] fix(osscluster): typo --- osscluster.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/osscluster.go b/osscluster.go index d68eff4f..0526022b 100644 --- a/osscluster.go +++ b/osscluster.go @@ -1583,15 +1583,15 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err func (c *ClusterClient) slottedKeyedCommands(cmds []Cmder) map[int][]Cmder { cmdsSlots := map[int][]Cmder{} - prefferedRandomSlot := -1 + preferredRandomSlot := -1 for _, cmd := range cmds { if cmdFirstKeyPos(cmd) == 0 { continue } - slot := c.cmdSlot(cmd, prefferedRandomSlot) - if prefferedRandomSlot == -1 { - prefferedRandomSlot = slot + slot := c.cmdSlot(cmd, preferredRandomSlot) + if preferredRandomSlot == -1 { + preferredRandomSlot = slot } cmdsSlots[slot] = append(cmdsSlots[slot], cmd)