e2e: run DeployCacheServerWithExternalEtcd with two cache-server replicas

Author: gman0

test/e2e/cacheserver/cacheserver_test.go

@@ -111,7 +111,7 @@ func TestCacheWithExternalEtcdAndRootShard(t *testing.T) {
 	namespace := utils.CreateSelfDestructingNamespace(t, ctx, client, "cache-with-etcd-rootshard")
 
 	// deploy the cache server
-	cacheServer := utils.DeployCacheServerWithExternalEtcd(ctx, t, client, namespace.Name)
+	cacheServer := utils.DeployCacheServerWithExternalEtcd(ctx, t, client, namespace.Name, 2)
 
 	// deploy a root shard that uses our cache
 	rootShard := utils.DeployRootShard(ctx, t, client, namespace.Name, "example.localhost", func(rs *operatorv1alpha1.RootShard) {

test/utils/deploy.go

@@ -285,12 +285,18 @@ func DeployCacheServer(ctx context.Context, t *testing.T, client ctrlruntimeclie
 	return server
 }
 
-func DeployCacheServerWithExternalEtcd(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, namespace string, patches ...func(*operatorv1alpha1.CacheServer)) operatorv1alpha1.CacheServer {
+func DeployCacheServerWithExternalEtcd(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, namespace string, replicas int32, patches ...func(*operatorv1alpha1.CacheServer)) operatorv1alpha1.CacheServer {
 	t.Helper()
 
 	etcd := DeployEtcd(t, "kachy-etcd", namespace)
 
+	if replicas < 1 {
+		replicas = 1
+	}
+
 	return DeployCacheServer(ctx, t, client, namespace, append(patches, func(server *operatorv1alpha1.CacheServer) {
+		server.Spec.Replicas = &replicas
+
 		server.Spec.Etcd = &operatorv1alpha1.EtcdConfig{
 			Endpoints: []string{etcd},
 		}