update template

Author: charleszheng44

config/component-templates/nested-etcd/nested-etcd-statefulset-template.yaml

@@ -43,7 +43,7 @@ spec:
         - --peer-key-file=/etc/kubernetes/pki/etcd/tls.key
         - --listen-peer-urls=https://0.0.0.0:2380
         - --listen-client-urls=https://0.0.0.0:2379
-        - --initial-advertise-peer-urls=https://$(HOSTNAME).{{.nestedetcdName}}:2380
+        # - --initial-advertise-peer-urls=https://$(HOSTNAME).{{.nestedetcdName}}:2380
         # we use a headless service to encapsulate each pod
         - --advertise-client-urls=https://$(HOSTNAME).{{.nestedetcdName}}:2379
         - --initial-cluster-state=new

controllers/controlplane/nestedetcd_controller.go

@@ -195,6 +195,10 @@ func createNestedEtcdStatefulSet(ctx context.Context, cli ctrlcli.Client,
 		}
 		netcdSts = stsObj
 		log.Info("convert runtime object to StatefulSet.")
+		// icaVal := genInitialClusterArgs(1, netcd.GetName(), netcd.GetName())
+		// stsArgs := append(netcdSts.Spec.Template.Spec.Containers[0].Args, "--initial-cluster", icaVal)
+		// netcdSts.Spec.Template.Spec.Containers[0].Args = stsArgs
+		// log.Info("set the '--initial-cluster' opt")
 
 		defaultSvcTmpl, err := fetchTemplate(defaultServiceURL)
 		if err != nil {
@@ -385,6 +389,23 @@ func getOwner(netcd controlplanev1alpha4.NestedEtcd) metav1.OwnerReference {
 	return metav1.OwnerReference{}
 }
 
+// genInitialClusterArgs generates the values for `--inital-cluster` option of etcd based on the number of
+// replicas specified in etcd StatefulSet
+func genInitialClusterArgs(replicas int32, stsName, svcName string) (argsVal string) {
+	for i := int32(0); i < replicas; i++ {
+		// use 2380 as the default port for etcd peer communication
+		peerAddr := fmt.Sprintf("%s-%d=https://%s-%d.%s:%d",
+			stsName, i, stsName, i, svcName, 2380)
+		if i == replicas-1 {
+			argsVal = argsVal + peerAddr
+			break
+		}
+		argsVal = argsVal + peerAddr + ","
+	}
+
+	return argsVal
+}
+
 // SetupWithManager sets up the controller with the Manager.
 func (r *NestedEtcdReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	if err := mgr.GetFieldIndexer().IndexField(context.TODO(),