Add option for using ramdisk for etcd

Signed-off-by: Pablo Chacin <[email protected]>

e2e/cluster/cluster_e2e_test.go

@@ -41,6 +41,30 @@ func Test_DefaultConfig(t *testing.T) {
 	cluster.Delete()
 }
 
+func Test_UseEtcdRamDisk(t *testing.T) {
+	// create cluster with default configuration
+	config, err := cluster.NewConfig(
+		"e2e-etcdramdisk-cluster",
+		cluster.Options{
+			Wait:           time.Second * 60,
+			UseEtcdRAMDisk: true,
+		},
+	)
+	if err != nil {
+		t.Errorf("failed creating cluster configuration: %v", err)
+		return
+	}
+
+	cluster, err := config.Create()
+	if err != nil {
+		t.Errorf("failed to create cluster: %v", err)
+		return
+	}
+
+	// delete cluster
+	cluster.Delete()
+}
+
 func getKubernetesClient(kubeconfig string) (kubernetes.Interface, error) {
 	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
 	if err != nil {
@@ -126,7 +150,6 @@ func Test_PreloadImages(t *testing.T) {
 	}
 }
 
-
 func Test_KubernetesVersion(t *testing.T) {
 	// create cluster with default configuration
 	config, err := cluster.NewConfig(

pkg/testutils/cluster/cluster.go

@@ -31,6 +31,14 @@ apiVersion: kind.x-k8s.io/v1alpha4
 nodes:
 - role: control-plane`
 
+const etcdPatch = `
+kubeadmConfigPatches:
+- |
+  kind: ClusterConfiguration
+  etcd:
+    local:
+      dataDir: /tmp/etcd`
+
 const kindPortMapping = `
   - containerPort: %d
     hostPort: %d
@@ -62,6 +70,8 @@ type Options struct {
 	Version string
 	// Path to Kubeconfig
 	Kubeconfig string
+	// UseEtcdRAMDisk
+	UseEtcdRAMDisk bool
 }
 
 // Config contains the configuration for creating a cluster
@@ -117,6 +127,10 @@ func (c *Config) Render() (string, error) {
 		fmt.Fprintf(&config, "\n- role: worker")
 	}
 
+	if c.options.UseEtcdRAMDisk {
+		fmt.Fprintf(&config, "\n%s", etcdPatch)
+	}
+
 	return config.String(), nil
 }