From 380e750b9e69e6d460d820d211a13ca065857ec7 Mon Sep 17 00:00:00 2001 From: Radek Simko Date: Tue, 4 Jul 2017 18:00:30 +0100 Subject: [PATCH] r/pod: Fix a crash caused by wrong field name --- kubernetes/resource_kubernetes_pod_test.go | 84 ++++++++++++++++++++-- kubernetes/structures_pod.go | 4 +- 2 files changed, 81 insertions(+), 7 deletions(-) diff --git a/kubernetes/resource_kubernetes_pod_test.go b/kubernetes/resource_kubernetes_pod_test.go index d4a048a918..789aab4953 100644 --- a/kubernetes/resource_kubernetes_pod_test.go +++ b/kubernetes/resource_kubernetes_pod_test.go @@ -268,6 +268,38 @@ func TestAccKubernetesPod_with_volume_mount(t *testing.T) { }) } +func TestAccKubernetesPod_with_cfg_map_volume_mount(t *testing.T) { + var conf api.Pod + + podName := fmt.Sprintf("tf-acc-test-%s", acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)) + cfgMap := fmt.Sprintf("tf-acc-test-%s", acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)) + + imageName := "nginx:1.7.9" + + resource.Test(t, resource.TestCase{ + PreCheck: func() { testAccPreCheck(t) }, + Providers: testAccProviders, + CheckDestroy: testAccCheckKubernetesPodDestroy, + Steps: []resource.TestStep{ + { + Config: testAccKubernetesPodConfigWithConfigMapVolume(cfgMap, podName, imageName), + Check: resource.ComposeAggregateTestCheckFunc( + testAccCheckKubernetesPodExists("kubernetes_pod.test", &conf), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.image", imageName), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.volume_mount.#", "1"), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.volume_mount.0.mount_path", "/tmp/my_path"), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.volume_mount.0.name", "cfg"), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.volume_mount.0.read_only", "false"), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.container.0.volume_mount.0.sub_path", ""), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.volume.0.name", "cfg"), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.volume.0.config_map.0.name", cfgMap), + resource.TestCheckResourceAttr("kubernetes_pod.test", "spec.0.volume.0.config_map.0.default_mode", "511"), // 0777 in decimal + ), + }, + }, + }) +} + func TestAccKubernetesPod_with_resource_requirements(t *testing.T) { var conf api.Pod @@ -642,14 +674,14 @@ resource "kubernetes_pod" "test" { container { image = "%s" name = "containername" - volume_mount { - mount_path = "/tmp/my_path" - name = "db" - } + volume_mount { + mount_path = "/tmp/my_path" + name = "db" + } } volume { name = "db" - secret = { + secret { secret_name = "${kubernetes_secret.test.metadata.0.name}" } } @@ -658,6 +690,48 @@ resource "kubernetes_pod" "test" { `, secretName, podName, imageName) } +func testAccKubernetesPodConfigWithConfigMapVolume(secretName, podName, imageName string) string { + return fmt.Sprintf(` +resource "kubernetes_config_map" "test" { + metadata { + name = "%s" + } + + data { + one = "first" + } +} + +resource "kubernetes_pod" "test" { + metadata { + labels { + app = "pod_label" + } + + name = "%s" + } + + spec { + container { + image = "%s" + name = "containername" + volume_mount { + mount_path = "/tmp/my_path" + name = "cfg" + } + } + volume { + name = "cfg" + config_map { + name = "${kubernetes_config_map.test.metadata.0.name}" + default_mode = 0777 + } + } + } +} + `, secretName, podName, imageName) +} + func testAccKubernetesPodConfigWithResourceRequirements(podName, imageName string) string { return fmt.Sprintf(` diff --git a/kubernetes/structures_pod.go b/kubernetes/structures_pod.go index 3cd69f0050..5caeed94ff 100644 --- a/kubernetes/structures_pod.go +++ b/kubernetes/structures_pod.go @@ -473,7 +473,7 @@ func expandConfigMapVolumeSource(l []interface{}) *v1.ConfigMapVolumeSource { } in := l[0].(map[string]interface{}) obj := &v1.ConfigMapVolumeSource{ - DefaultMode: ptrToInt32(int32(in["default_mode "].(int))), + DefaultMode: ptrToInt32(int32(in["default_mode"].(int))), } if v, ok := in["name"].(string); ok { @@ -493,7 +493,7 @@ func expandDownwardAPIVolumeSource(l []interface{}) (*v1.DownwardAPIVolumeSource } in := l[0].(map[string]interface{}) obj := &v1.DownwardAPIVolumeSource{ - DefaultMode: ptrToInt32(int32(in["default_mode "].(int))), + DefaultMode: ptrToInt32(int32(in["default_mode"].(int))), } if v, ok := in["items"].([]interface{}); ok && len(v) > 0 { var err error