Add init container to the gateway to wait for node readiness

See submariner-io/submariner#3222 Signed-off-by: Tom Pantelis <tompantelis@gmail.com>
tpantelis · Nov 21, 2024 · f46ddb6 · f46ddb6
1 parent 7e87cbb
commit f46ddb6
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 13 deletions.
diff --git a/controllers/submariner/gateway_resources.go b/controllers/submariner/gateway_resources.go
@@ -133,6 +133,19 @@ func newGatewayPodTemplate(cr *v1alpha1.Submariner, name string, podSelectorLabe
 		})
 	}
 
+	securityContext := &corev1.SecurityContext{
+		Capabilities: &corev1.Capabilities{
+			Add:  []corev1.Capability{"net_admin"},
+			Drop: []corev1.Capability{"all"},
+		},
+		// The gateway needs to be privileged so it can write to /proc/sys
+		AllowPrivilegeEscalation: ptr.To(true),
+		Privileged:               ptr.To(true),
+		RunAsNonRoot:             ptr.To(false),
+		// We need to be able to update /var/lib/alternatives (for iptables)
+		ReadOnlyRootFilesystem: ptr.To(false),
+	}
+
 	podTemplate := corev1.PodTemplateSpec{
 		ObjectMeta: metav1.ObjectMeta{
 			Labels: podSelectorLabels,
@@ -149,23 +162,29 @@ func newGatewayPodTemplate(cr *v1alpha1.Submariner, name string, podSelectorLabe
 				},
 			},
 			NodeSelector: map[string]string{"submariner.io/gateway": "true"},
+			// Wait for the node to be ready before starting the gateway.
+			InitContainers: []corev1.Container{
+				{
+					Name:            name + "-init",
+					Image:           getImagePath(cr, opnames.GatewayImage, names.GatewayComponent),
+					ImagePullPolicy: images.GetPullPolicy(cr.Spec.Version, cr.Spec.ImageOverrides[names.GatewayComponent]),
+					SecurityContext: securityContext,
+					Env: httpproxy.AddEnvVars([]corev1.EnvVar{
+						{Name: "SUBMARINER_WAITFORNODE", Value: "true"},
+						{Name: "NODE_NAME", ValueFrom: &corev1.EnvVarSource{
+							FieldRef: &corev1.ObjectFieldSelector{
+								FieldPath: "spec.nodeName",
+							},
+						}},
+					}),
+				},
+			},
 			Containers: []corev1.Container{
 				{
 					Name:            name,
 					Image:           getImagePath(cr, opnames.GatewayImage, names.GatewayComponent),
 					ImagePullPolicy: images.GetPullPolicy(cr.Spec.Version, cr.Spec.ImageOverrides[names.GatewayComponent]),
-					SecurityContext: &corev1.SecurityContext{
-						Capabilities: &corev1.Capabilities{
-							Add:  []corev1.Capability{"net_admin"},
-							Drop: []corev1.Capability{"all"},
-						},
-						// The gateway needs to be privileged so it can write to /proc/sys
-						AllowPrivilegeEscalation: ptr.To(true),
-						Privileged:               ptr.To(true),
-						RunAsNonRoot:             ptr.To(false),
-						// We need to be able to update /var/lib/alternatives (for iptables)
-						ReadOnlyRootFilesystem: ptr.To(false),
-					},
+					SecurityContext: securityContext,
 					Ports: []corev1.ContainerPort{
 						{
 							Name:          encapsPortName,

diff --git a/controllers/submariner/route_agent_resources.go b/controllers/submariner/route_agent_resources.go
@@ -110,7 +110,6 @@ func newRouteAgentDaemonSet(cr *v1alpha1.Submariner, name string) *appsv1.Daemon
 							Name:            name + "-init",
 							Image:           getImagePath(cr, opnames.RouteAgentImage, names.RouteAgentComponent),
 							ImagePullPolicy: images.GetPullPolicy(cr.Spec.Version, cr.Spec.ImageOverrides[names.RouteAgentComponent]),
-							Command:         []string{"submariner-route-agent.sh"},
 							Env: httpproxy.AddEnvVars([]corev1.EnvVar{
 								{Name: "SUBMARINER_WAITFORNODE", Value: "true"},
 								{Name: "NODE_NAME", ValueFrom: &corev1.EnvVarSource{