fix sqs url for china

kubernetes · Apr 9, 2021 · fe7c9a4 · fe7c9a4
1 parent 7fa7338
commit fe7c9a4
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/upup/pkg/fi/cloudup/template_functions.go b/upup/pkg/fi/cloudup/template_functions.go
@@ -220,7 +220,11 @@ func (tf *TemplateFunctions) AddTo(dest template.FuncMap, secretStore fi.SecretS
 	if cluster.Spec.NodeTerminationHandler != nil {
 		dest["DefaultQueueName"] = func() string {
 			s := strings.Replace(tf.ClusterName(), ".", "-", -1)
-			url := "https://sqs." + tf.Region + ".amazonaws.com/" + tf.AWSAccountID + "/" + s + "-nth"
+			domain := ".amazonaws.com/"
+			if strings.Contains(tf.Region, "cn-") {
+				domain = ".amazonaws.com.cn/"
+			}
+			url := "https://sqs." + tf.Region + domain + tf.AWSAccountID + "/" + s + "-nth"
 			return url
 		}
 	}