perf: avoid unnecessary connections for CLUSTER SHARDS when auto pipelining is disabled

rueian · rueian · commit 8d5a37fbe2b6 · 2025-03-15T11:34:56.000-07:00
Signed-off-by: Rueian &lt;rueiancsie@gmail.com&gt;
diff --git a/internal/cmds/cmds.go b/internal/cmds/cmds.go
@@ -39,6 +39,7 @@ var (
 	// RoleCmd is predefined ROLE
 	RoleCmd = Completed{
 		cs: newCommandSlice([]string{"ROLE"}),
+		cf: pipeTag,
 	}
 
 	// UnsubscribeCmd is predefined UNSUBSCRIBE
@@ -63,10 +64,12 @@ var (
 	// SlotCmd is predefined CLUSTER SLOTS
 	SlotCmd = Completed{
 		cs: newCommandSlice([]string{"CLUSTER", "SLOTS"}),
+		cf: pipeTag,
 	}
 	// ShardsCmd is predefined CLUSTER SHARDS
 	ShardsCmd = Completed{
 		cs: newCommandSlice([]string{"CLUSTER", "SHARDS"}),
+		cf: pipeTag,
 	}
 	// AskingCmd is predefined CLUSTER ASKING
 	AskingCmd = Completed{

Original file line number	Diff line number	Diff line change
`@@ -39,6 +39,7 @@ var (`
`39`	`39`	`// RoleCmd is predefined ROLE`
`40`	`40`	`RoleCmd = Completed{`
`41`	`41`	`cs: newCommandSlice([]string{"ROLE"}),`
	`42`	`+ cf: pipeTag,`
`42`	`43`	`}`
`43`	`44`
`44`	`45`	`// UnsubscribeCmd is predefined UNSUBSCRIBE`
`@@ -63,10 +64,12 @@ var (`
`63`	`64`	`// SlotCmd is predefined CLUSTER SLOTS`
`64`	`65`	`SlotCmd = Completed{`
`65`	`66`	`cs: newCommandSlice([]string{"CLUSTER", "SLOTS"}),`
	`67`	`+ cf: pipeTag,`
`66`	`68`	`}`
`67`	`69`	`// ShardsCmd is predefined CLUSTER SHARDS`
`68`	`70`	`ShardsCmd = Completed{`
`69`	`71`	`cs: newCommandSlice([]string{"CLUSTER", "SHARDS"}),`
	`72`	`+ cf: pipeTag,`
`70`	`73`	`}`
`71`	`74`	`// AskingCmd is predefined CLUSTER ASKING`
`72`	`75`	`AskingCmd = Completed{`