Method createSlotSpecificCommand

osscluster_router.go:183–199

createSlotSpecificCommand creates a new command for a specific slot's keys. firstKeyPos is passed in from the caller (computed once in executeMultiShard) so this function never independently re-peeks the cache — avoids the cold --> warm inconsistency the reviewer flagged.

(ctx context.Context, originalCmd Cmder, keys []string, firstKeyPos int)

// so this function never independently re-peeks the cache — avoids the
// cold --> warm inconsistency the reviewer flagged.
func (c *ClusterClient) createSlotSpecificCommand(ctx context.Context, originalCmd Cmder, keys []string, firstKeyPos int) Cmder {
	originalArgs := originalCmd.Args()

	// Build new args with only the specified keys
	newArgs := make([]interface{}, 0, firstKeyPos+len(keys))

	// Copy command name and arguments before the keys
	newArgs = append(newArgs, originalArgs[:firstKeyPos]...)

	// Add the slot-specific keys
	for _, key := range keys {
		newArgs = append(newArgs, key)
	}

	// Create a new command of the same type using the helper function
	return createCommandByType(ctx, originalCmd.GetCmdType(), newArgs...)
}

// createCommandByType creates a new command of the specified type with the given arguments
func createCommandByType(ctx context.Context, cmdType CmdType, args ...interface{}) Cmder {