Assign 700MB to each node (#1402)

Author: mkuratczyk

system_tests/system_test.go

@@ -15,12 +15,13 @@ import (
 	"crypto/x509"
 	"encoding/json"
 	"fmt"
-	"golang.org/x/mod/semver"
 	"io/ioutil"
 	"strconv"
 	"strings"
 	"time"
 
+	"golang.org/x/mod/semver"
+	corev1 "k8s.io/api/core/v1"
 	k8sresource "k8s.io/apimachinery/pkg/api/resource"
 	"k8s.io/apimachinery/pkg/types"
 
@@ -374,6 +375,14 @@ CONSOLE_LOG=new`
 			BeforeEach(func() {
 				cluster = newRabbitmqCluster(namespace, "ha-rabbit")
 				cluster.Spec.Replicas = pointer.Int32(3)
+				cluster.Spec.Resources = &corev1.ResourceRequirements{
+					Requests: corev1.ResourceList{
+						corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+					},
+					Limits: corev1.ResourceList{
+						corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+					},
+				}
 
 				Expect(createRabbitmqCluster(ctx, rmqClusterClient, cluster)).To(Succeed())
 				waitForRabbitmqRunning(cluster)
@@ -430,6 +439,14 @@ CONSOLE_LOG=new`
 					"rabbitmq_mqtt",
 					"rabbitmq_stomp",
 				}
+				cluster.Spec.Resources = &corev1.ResourceRequirements{
+					Requests: corev1.ResourceList{
+						corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+					},
+					Limits: corev1.ResourceList{
+						corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+					},
+				}
 				Expect(createRabbitmqCluster(ctx, rmqClusterClient, cluster)).To(Succeed())
 				waitForRabbitmqRunning(cluster)
 
@@ -571,6 +588,14 @@ CONSOLE_LOG=new`
 				"rabbitmq_stomp",
 				"rabbitmq_stream",
 			}
+			cluster.Spec.Resources = &corev1.ResourceRequirements{
+				Requests: corev1.ResourceList{
+					corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+				},
+				Limits: corev1.ResourceList{
+					corev1.ResourceMemory: k8sresource.MustParse("700Mi"),
+				},
+			}
 			Expect(createRabbitmqCluster(ctx, rmqClusterClient, cluster)).To(Succeed())
 			waitForRabbitmqRunning(cluster)
 			waitForPortReadiness(cluster, 1883)  // mqtt