TestMu Conference is Back! Future of Testing + AI LambdaTest G2 Announcement

How to use Create method of configmap Package

Best Testkube code snippet using configmap.Create

configmap_volume.go

Source:configmap_volume.go

...26	f := framework.NewDefaultFramework("configmap")27	/*28		Release : v1.929		Testname: ConfigMap Volume, without mapping30		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The data content of the file MUST be readable and verified and file modes MUST default to 0x644.31	*/32	framework.ConformanceIt("should be consumable from pods in volume [NodeConformance]", func() {33		doConfigMapE2EWithoutMappings(f, 0, 0, nil)34	})35	/*36		Release : v1.937		Testname: ConfigMap Volume, without mapping, volume mode set38		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. File mode is changed to a custom value of '0x400'. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The data content of the file MUST be readable and verified and file modes MUST be set to the custom value of â0x400â39		This test is marked LinuxOnly since Windows does not support setting specific file permissions.40	*/41	framework.ConformanceIt("should be consumable from pods in volume with defaultMode set [LinuxOnly] [NodeConformance]", func() {42		defaultMode := int32(0400)43		doConfigMapE2EWithoutMappings(f, 0, 0, &defaultMode)44	})45	It("should be consumable from pods in volume as non-root with defaultMode and fsGroup set [NodeFeature:FSGroup]", func() {46		defaultMode := int32(0440) /* setting fsGroup sets mode to at least 440 */47		doConfigMapE2EWithoutMappings(f, 1000, 1001, &defaultMode)48	})49	/*50		Release : v1.951		Testname: ConfigMap Volume, without mapping, non-root user52		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. Pod is run as a non-root user with uid=1000. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The file on the volume MUST have file mode set to default value of 0x644.53		This test is marked LinuxOnly since Windows does not support running as UID / GID.54	*/55	framework.ConformanceIt("should be consumable from pods in volume as non-root [LinuxOnly] [NodeConformance]", func() {56		doConfigMapE2EWithoutMappings(f, 1000, 0, nil)57	})58	It("should be consumable from pods in volume as non-root with FSGroup [NodeFeature:FSGroup]", func() {59		doConfigMapE2EWithoutMappings(f, 1000, 1001, nil)60	})61	/*62		Release : v1.963		Testname: ConfigMap Volume, with mapping64		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. Files are mapped to a path in the volume. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The data content of the file MUST be readable and verified and file modes MUST default to 0x644.65	*/66	framework.ConformanceIt("should be consumable from pods in volume with mappings [NodeConformance]", func() {67		doConfigMapE2EWithMappings(f, 0, 0, nil)68	})69	/*70		Release : v1.971		Testname: ConfigMap Volume, with mapping, volume mode set72		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. Files are mapped to a path in the volume. File mode is changed to a custom value of '0x400'. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The data content of the file MUST be readable and verified and file modes MUST be set to the custom value of â0x400â73		This test is marked LinuxOnly since Windows does not support setting specific file permissions.74	*/75	framework.ConformanceIt("should be consumable from pods in volume with mappings and Item mode set [LinuxOnly] [NodeConformance]", func() {76		mode := int32(0400)77		doConfigMapE2EWithMappings(f, 0, 0, &mode)78	})79	/*80		Release : v1.981		Testname: ConfigMap Volume, with mapping, non-root user82		Description: Create a ConfigMap, create a Pod that mounts a volume and populates the volume with data stored in the ConfigMap. Files are mapped to a path in the volume. Pod is run as a non-root user with uid=1000. The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount. The file on the volume MUST have file mode set to default value of 0x644.83		This test is marked LinuxOnly since Windows does not support running as UID / GID.84	*/85	framework.ConformanceIt("should be consumable from pods in volume with mappings as non-root [LinuxOnly] [NodeConformance]", func() {86		doConfigMapE2EWithMappings(f, 1000, 0, nil)87	})88	It("should be consumable from pods in volume with mappings as non-root with FSGroup [NodeFeature:FSGroup]", func() {89		doConfigMapE2EWithMappings(f, 1000, 1001, nil)90	})91	/*92		Release : v1.993		Testname: ConfigMap Volume, update94		Description: The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount that is mapped to custom path in the Pod. When the ConfigMap is updated the change to the config map MUST be verified by reading the content from the mounted file in the Pod.95	*/96	framework.ConformanceIt("updates should be reflected in volume [NodeConformance]", func() {97		podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)98		containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))99		name := "configmap-test-upd-" + string(uuid.NewUUID())100		volumeName := "configmap-volume"101		volumeMountPath := "/etc/configmap-volume"102		containerName := "configmap-volume-test"103		configMap := &v1.ConfigMap{104			ObjectMeta: metav1.ObjectMeta{105				Namespace: f.Namespace.Name,106				Name:      name,107			},108			Data: map[string]string{109				"data-1": "value-1",110			},111		}112		By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))113		var err error114		if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {115			framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)116		}117		pod := &v1.Pod{118			ObjectMeta: metav1.ObjectMeta{119				Name: "pod-configmaps-" + string(uuid.NewUUID()),120			},121			Spec: v1.PodSpec{122				Volumes: []v1.Volume{123					{124						Name: volumeName,125						VolumeSource: v1.VolumeSource{126							ConfigMap: &v1.ConfigMapVolumeSource{127								LocalObjectReference: v1.LocalObjectReference{128									Name: name,129								},130							},131						},132					},133				},134				Containers: []v1.Container{135					{136						Name:    containerName,137						Image:   imageutils.GetE2EImage(imageutils.Mounttest),138						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volume/data-1"},139						VolumeMounts: []v1.VolumeMount{140							{141								Name:      volumeName,142								MountPath: volumeMountPath,143								ReadOnly:  true,144							},145						},146					},147				},148				RestartPolicy: v1.RestartPolicyNever,149			},150		}151		By("Creating the pod")152		f.PodClient().CreateSync(pod)153		pollLogs := func() (string, error) {154			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, containerName)155		}156		Eventually(pollLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("value-1"))157		By(fmt.Sprintf("Updating configmap %v", configMap.Name))158		configMap.ResourceVersion = "" // to force update159		configMap.Data["data-1"] = "value-2"160		_, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Update(configMap)161		framework.ExpectNoError(err, "Failed to update configmap %q in namespace %q", configMap.Name, f.Namespace.Name)162		By("waiting to observe update in volume")163		Eventually(pollLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("value-2"))164	})165	/*166		Release: v1.12167		Testname: ConfigMap Volume, text data, binary data168		Description: The ConfigMap that is created with text data and binary data MUST be accessible to read from the newly created Pod using the volume mount that is mapped to custom path in the Pod. ConfigMap's text data and binary data MUST be verified by reading the content from the mounted files in the Pod.169	*/170	framework.ConformanceIt("binary data should be reflected in volume [NodeConformance]", func() {171		podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)172		containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))173		name := "configmap-test-upd-" + string(uuid.NewUUID())174		volumeName := "configmap-volume"175		volumeMountPath := "/etc/configmap-volume"176		containerName1 := "configmap-volume-data-test"177		containerName2 := "configmap-volume-binary-test"178		configMap := &v1.ConfigMap{179			ObjectMeta: metav1.ObjectMeta{180				Namespace: f.Namespace.Name,181				Name:      name,182			},183			Data: map[string]string{184				"data-1": "value-1",185			},186			BinaryData: map[string][]byte{187				"dump.bin": {0xde, 0xca, 0xfe, 0xba, 0xd0, 0xfe, 0xff},188			},189		}190		By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))191		var err error192		if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {193			framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)194		}195		pod := &v1.Pod{196			ObjectMeta: metav1.ObjectMeta{197				Name: "pod-configmaps-" + string(uuid.NewUUID()),198			},199			Spec: v1.PodSpec{200				Volumes: []v1.Volume{201					{202						Name: volumeName,203						VolumeSource: v1.VolumeSource{204							ConfigMap: &v1.ConfigMapVolumeSource{205								LocalObjectReference: v1.LocalObjectReference{206									Name: name,207								},208							},209						},210					},211				},212				Containers: []v1.Container{213					{214						Name:    containerName1,215						Image:   imageutils.GetE2EImage(imageutils.Mounttest),216						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volume/data-1"},217						VolumeMounts: []v1.VolumeMount{218							{219								Name:      volumeName,220								MountPath: volumeMountPath,221								ReadOnly:  true,222							},223						},224					},225					{226						Name:    containerName2,227						Image:   imageutils.GetE2EImage(imageutils.BusyBox),228						Command: []string{"hexdump", "-C", "/etc/configmap-volume/dump.bin"},229						VolumeMounts: []v1.VolumeMount{230							{231								Name:      volumeName,232								MountPath: volumeMountPath,233								ReadOnly:  true,234							},235						},236					},237				},238				RestartPolicy: v1.RestartPolicyNever,239			},240		}241		By("Creating the pod")242		f.PodClient().CreateSync(pod)243		pollLogs1 := func() (string, error) {244			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, containerName1)245		}246		pollLogs2 := func() (string, error) {247			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, containerName2)248		}249		By("Waiting for pod with text data")250		Eventually(pollLogs1, podLogTimeout, framework.Poll).Should(ContainSubstring("value-1"))251		By("Waiting for pod with binary data")252		Eventually(pollLogs2, podLogTimeout, framework.Poll).Should(ContainSubstring("de ca fe ba d0 fe ff"))253	})254	/*255		Release : v1.9256		Testname: ConfigMap Volume, create, update and delete257		Description: The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount that is mapped to custom path in the Pod. When the config map is updated the change to the config map MUST be verified by reading the content from the mounted file in the Pod. Also when the item(file) is deleted from the map that MUST result in a error reading that item(file).258	*/259	framework.ConformanceIt("optional updates should be reflected in volume [NodeConformance]", func() {260		podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)261		containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))262		trueVal := true263		volumeMountPath := "/etc/configmap-volumes"264		deleteName := "cm-test-opt-del-" + string(uuid.NewUUID())265		deleteContainerName := "delcm-volume-test"266		deleteVolumeName := "deletecm-volume"267		deleteConfigMap := &v1.ConfigMap{268			ObjectMeta: metav1.ObjectMeta{269				Namespace: f.Namespace.Name,270				Name:      deleteName,271			},272			Data: map[string]string{273				"data-1": "value-1",274			},275		}276		updateName := "cm-test-opt-upd-" + string(uuid.NewUUID())277		updateContainerName := "updcm-volume-test"278		updateVolumeName := "updatecm-volume"279		updateConfigMap := &v1.ConfigMap{280			ObjectMeta: metav1.ObjectMeta{281				Namespace: f.Namespace.Name,282				Name:      updateName,283			},284			Data: map[string]string{285				"data-1": "value-1",286			},287		}288		createName := "cm-test-opt-create-" + string(uuid.NewUUID())289		createContainerName := "createcm-volume-test"290		createVolumeName := "createcm-volume"291		createConfigMap := &v1.ConfigMap{292			ObjectMeta: metav1.ObjectMeta{293				Namespace: f.Namespace.Name,294				Name:      createName,295			},296			Data: map[string]string{297				"data-1": "value-1",298			},299		}300		By(fmt.Sprintf("Creating configMap with name %s", deleteConfigMap.Name))301		var err error302		if deleteConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(deleteConfigMap); err != nil {303			framework.Failf("unable to create test configMap %s: %v", deleteConfigMap.Name, err)304		}305		By(fmt.Sprintf("Creating configMap with name %s", updateConfigMap.Name))306		if updateConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(updateConfigMap); err != nil {307			framework.Failf("unable to create test configMap %s: %v", updateConfigMap.Name, err)308		}309		pod := &v1.Pod{310			ObjectMeta: metav1.ObjectMeta{311				Name: "pod-configmaps-" + string(uuid.NewUUID()),312			},313			Spec: v1.PodSpec{314				Volumes: []v1.Volume{315					{316						Name: deleteVolumeName,317						VolumeSource: v1.VolumeSource{318							ConfigMap: &v1.ConfigMapVolumeSource{319								LocalObjectReference: v1.LocalObjectReference{320									Name: deleteName,321								},322								Optional: &trueVal,323							},324						},325					},326					{327						Name: updateVolumeName,328						VolumeSource: v1.VolumeSource{329							ConfigMap: &v1.ConfigMapVolumeSource{330								LocalObjectReference: v1.LocalObjectReference{331									Name: updateName,332								},333								Optional: &trueVal,334							},335						},336					},337					{338						Name: createVolumeName,339						VolumeSource: v1.VolumeSource{340							ConfigMap: &v1.ConfigMapVolumeSource{341								LocalObjectReference: v1.LocalObjectReference{342									Name: createName,343								},344								Optional: &trueVal,345							},346						},347					},348				},349				Containers: []v1.Container{350					{351						Name:    deleteContainerName,352						Image:   imageutils.GetE2EImage(imageutils.Mounttest),353						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volumes/delete/data-1"},354						VolumeMounts: []v1.VolumeMount{355							{356								Name:      deleteVolumeName,357								MountPath: path.Join(volumeMountPath, "delete"),358								ReadOnly:  true,359							},360						},361					},362					{363						Name:    updateContainerName,364						Image:   imageutils.GetE2EImage(imageutils.Mounttest),365						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volumes/update/data-3"},366						VolumeMounts: []v1.VolumeMount{367							{368								Name:      updateVolumeName,369								MountPath: path.Join(volumeMountPath, "update"),370								ReadOnly:  true,371							},372						},373					},374					{375						Name:    createContainerName,376						Image:   imageutils.GetE2EImage(imageutils.Mounttest),377						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volumes/create/data-1"},378						VolumeMounts: []v1.VolumeMount{379							{380								Name:      createVolumeName,381								MountPath: path.Join(volumeMountPath, "create"),382								ReadOnly:  true,383							},384						},385					},386				},387				RestartPolicy: v1.RestartPolicyNever,388			},389		}390		By("Creating the pod")391		f.PodClient().CreateSync(pod)392		pollCreateLogs := func() (string, error) {393			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, createContainerName)394		}395		Eventually(pollCreateLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("Error reading file /etc/configmap-volumes/create/data-1"))396		pollUpdateLogs := func() (string, error) {397			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, updateContainerName)398		}399		Eventually(pollUpdateLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("Error reading file /etc/configmap-volumes/update/data-3"))400		pollDeleteLogs := func() (string, error) {401			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, deleteContainerName)402		}403		Eventually(pollDeleteLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("value-1"))404		By(fmt.Sprintf("Deleting configmap %v", deleteConfigMap.Name))405		err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Delete(deleteConfigMap.Name, &metav1.DeleteOptions{})406		framework.ExpectNoError(err, "Failed to delete configmap %q in namespace %q", deleteConfigMap.Name, f.Namespace.Name)407		By(fmt.Sprintf("Updating configmap %v", updateConfigMap.Name))408		updateConfigMap.ResourceVersion = "" // to force update409		delete(updateConfigMap.Data, "data-1")410		updateConfigMap.Data["data-3"] = "value-3"411		_, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Update(updateConfigMap)412		framework.ExpectNoError(err, "Failed to update configmap %q in namespace %q", updateConfigMap.Name, f.Namespace.Name)413		By(fmt.Sprintf("Creating configMap with name %s", createConfigMap.Name))414		if createConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(createConfigMap); err != nil {415			framework.Failf("unable to create test configMap %s: %v", createConfigMap.Name, err)416		}417		By("waiting to observe update in volume")418		Eventually(pollCreateLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("value-1"))419		Eventually(pollUpdateLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("value-3"))420		Eventually(pollDeleteLogs, podLogTimeout, framework.Poll).Should(ContainSubstring("Error reading file /etc/configmap-volumes/delete/data-1"))421	})422	/*423		Release : v1.9424		Testname: ConfigMap Volume, multiple volume maps425		Description: The ConfigMap that is created MUST be accessible to read from the newly created Pod using the volume mount that is mapped to multiple paths in the Pod. The content MUST be accessible from all the mapped volume mounts.426	*/427	framework.ConformanceIt("should be consumable in multiple volumes in the same pod [NodeConformance]", func() {428		var (429			name             = "configmap-test-volume-" + string(uuid.NewUUID())430			volumeName       = "configmap-volume"431			volumeMountPath  = "/etc/configmap-volume"432			volumeName2      = "configmap-volume-2"433			volumeMountPath2 = "/etc/configmap-volume-2"434			configMap        = newConfigMap(f, name)435		)436		By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))437		var err error438		if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {439			framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)440		}441		pod := &v1.Pod{442			ObjectMeta: metav1.ObjectMeta{443				Name: "pod-configmaps-" + string(uuid.NewUUID()),444			},445			Spec: v1.PodSpec{446				Volumes: []v1.Volume{447					{448						Name: volumeName,449						VolumeSource: v1.VolumeSource{450							ConfigMap: &v1.ConfigMapVolumeSource{451								LocalObjectReference: v1.LocalObjectReference{452									Name: name,453								},454							},455						},456					},457					{458						Name: volumeName2,459						VolumeSource: v1.VolumeSource{460							ConfigMap: &v1.ConfigMapVolumeSource{461								LocalObjectReference: v1.LocalObjectReference{462									Name: name,463								},464							},465						},466					},467				},468				Containers: []v1.Container{469					{470						Name:  "configmap-volume-test",471						Image: imageutils.GetE2EImage(imageutils.Mounttest),472						Args:  []string{"--file_content=/etc/configmap-volume/data-1"},473						VolumeMounts: []v1.VolumeMount{474							{475								Name:      volumeName,476								MountPath: volumeMountPath,477								ReadOnly:  true,478							},479							{480								Name:      volumeName2,481								MountPath: volumeMountPath2,482								ReadOnly:  true,483							},484						},485					},486				},487				RestartPolicy: v1.RestartPolicyNever,488			},489		}490		f.TestContainerOutput("consume configMaps", pod, 0, []string{491			"content of file \"/etc/configmap-volume/data-1\": value-1",492		})493	})494	//The pod is in pending during volume creation until the configMap objects are available495	//or until mount the configMap volume times out. There is no configMap object defined for the pod, so it should return timout exception unless it is marked optional.496	//Slow (~5 mins)497	It("Should fail non-optional pod creation due to configMap object does not exist [Slow]", func() {498		volumeMountPath := "/etc/configmap-volumes"499		podName := "pod-configmaps-" + string(uuid.NewUUID())500		err := createNonOptionalConfigMapPod(f, volumeMountPath, podName)501		framework.ExpectError(err, "created pod %q with non-optional configMap in namespace %q", podName, f.Namespace.Name)502	})503	//ConfigMap object defined for the pod, If a key is specified which is not present in the ConfigMap,504	// the volume setup will error unless it is marked optional, during the pod creation.505	//Slow (~5 mins)506	It("Should fail non-optional pod creation due to the key in the configMap object does not exist [Slow]", func() {507		volumeMountPath := "/etc/configmap-volumes"508		podName := "pod-configmaps-" + string(uuid.NewUUID())509		err := createNonOptionalConfigMapPodWithConfig(f, volumeMountPath, podName)510		framework.ExpectError(err, "created pod %q with non-optional configMap in namespace %q", podName, f.Namespace.Name)511	})512})513func newConfigMap(f *framework.Framework, name string) *v1.ConfigMap {514	return &v1.ConfigMap{515		ObjectMeta: metav1.ObjectMeta{516			Namespace: f.Namespace.Name,517			Name:      name,518		},519		Data: map[string]string{520			"data-1": "value-1",521			"data-2": "value-2",522			"data-3": "value-3",523		},524	}525}526func doConfigMapE2EWithoutMappings(f *framework.Framework, uid, fsGroup int64, defaultMode *int32) {527	userID := int64(uid)528	groupID := int64(fsGroup)529	var (530		name            = "configmap-test-volume-" + string(uuid.NewUUID())531		volumeName      = "configmap-volume"532		volumeMountPath = "/etc/configmap-volume"533		configMap       = newConfigMap(f, name)534	)535	By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))536	var err error537	if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {538		framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)539	}540	one := int64(1)541	pod := &v1.Pod{542		ObjectMeta: metav1.ObjectMeta{543			Name: "pod-configmaps-" + string(uuid.NewUUID()),544		},545		Spec: v1.PodSpec{546			SecurityContext: &v1.PodSecurityContext{},547			Volumes: []v1.Volume{548				{549					Name: volumeName,550					VolumeSource: v1.VolumeSource{551						ConfigMap: &v1.ConfigMapVolumeSource{552							LocalObjectReference: v1.LocalObjectReference{553								Name: name,554							},555						},556					},557				},558			},559			Containers: []v1.Container{560				{561					Name:  "configmap-volume-test",562					Image: imageutils.GetE2EImage(imageutils.Mounttest),563					Args: []string{564						"--file_content=/etc/configmap-volume/data-1",565						"--file_mode=/etc/configmap-volume/data-1"},566					VolumeMounts: []v1.VolumeMount{567						{568							Name:      volumeName,569							MountPath: volumeMountPath,570						},571					},572				},573			},574			RestartPolicy:                 v1.RestartPolicyNever,575			TerminationGracePeriodSeconds: &one,576		},577	}578	if userID != 0 {579		pod.Spec.SecurityContext.RunAsUser = &userID580	}581	if groupID != 0 {582		pod.Spec.SecurityContext.FSGroup = &groupID583	}584	if defaultMode != nil {585		pod.Spec.Volumes[0].VolumeSource.ConfigMap.DefaultMode = defaultMode586	}587	fileModeRegexp := framework.GetFileModeRegex("/etc/configmap-volume/data-1", defaultMode)588	output := []string{589		"content of file \"/etc/configmap-volume/data-1\": value-1",590		fileModeRegexp,591	}592	f.TestContainerOutputRegexp("consume configMaps", pod, 0, output)593}594func doConfigMapE2EWithMappings(f *framework.Framework, uid, fsGroup int64, itemMode *int32) {595	userID := int64(uid)596	groupID := int64(fsGroup)597	var (598		name            = "configmap-test-volume-map-" + string(uuid.NewUUID())599		volumeName      = "configmap-volume"600		volumeMountPath = "/etc/configmap-volume"601		configMap       = newConfigMap(f, name)602	)603	By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))604	var err error605	if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {606		framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)607	}608	one := int64(1)609	pod := &v1.Pod{610		ObjectMeta: metav1.ObjectMeta{611			Name: "pod-configmaps-" + string(uuid.NewUUID()),612		},613		Spec: v1.PodSpec{614			SecurityContext: &v1.PodSecurityContext{},615			Volumes: []v1.Volume{616				{617					Name: volumeName,618					VolumeSource: v1.VolumeSource{619						ConfigMap: &v1.ConfigMapVolumeSource{620							LocalObjectReference: v1.LocalObjectReference{621								Name: name,622							},623							Items: []v1.KeyToPath{624								{625									Key:  "data-2",626									Path: "path/to/data-2",627								},628							},629						},630					},631				},632			},633			Containers: []v1.Container{634				{635					Name:  "configmap-volume-test",636					Image: imageutils.GetE2EImage(imageutils.Mounttest),637					Args: []string{"--file_content=/etc/configmap-volume/path/to/data-2",638						"--file_mode=/etc/configmap-volume/path/to/data-2"},639					VolumeMounts: []v1.VolumeMount{640						{641							Name:      volumeName,642							MountPath: volumeMountPath,643							ReadOnly:  true,644						},645					},646				},647			},648			RestartPolicy:                 v1.RestartPolicyNever,649			TerminationGracePeriodSeconds: &one,650		},651	}652	if userID != 0 {653		pod.Spec.SecurityContext.RunAsUser = &userID654	}655	if groupID != 0 {656		pod.Spec.SecurityContext.FSGroup = &groupID657	}658	if itemMode != nil {659		pod.Spec.Volumes[0].VolumeSource.ConfigMap.Items[0].Mode = itemMode660	}661	// Just check file mode if fsGroup is not set. If fsGroup is set, the662	// final mode is adjusted and we are not testing that case.663	output := []string{664		"content of file \"/etc/configmap-volume/path/to/data-2\": value-2",665	}666	if fsGroup == 0 {667		fileModeRegexp := framework.GetFileModeRegex("/etc/configmap-volume/path/to/data-2", itemMode)668		output = append(output, fileModeRegexp)669	}670	f.TestContainerOutputRegexp("consume configMaps", pod, 0, output)671}672func createNonOptionalConfigMapPod(f *framework.Framework, volumeMountPath, podName string) error {673	podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)674	containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))675	falseValue := false676	createName := "cm-test-opt-create-" + string(uuid.NewUUID())677	createContainerName := "createcm-volume-test"678	createVolumeName := "createcm-volume"679	//creating a pod without configMap object created, by mentioning the configMap volume source's local reference name680	pod := &v1.Pod{681		ObjectMeta: metav1.ObjectMeta{682			Name: podName,683		},684		Spec: v1.PodSpec{685			Volumes: []v1.Volume{686				{687					Name: createVolumeName,688					VolumeSource: v1.VolumeSource{689						ConfigMap: &v1.ConfigMapVolumeSource{690							LocalObjectReference: v1.LocalObjectReference{691								Name: createName,692							},693							Optional: &falseValue,694						},695					},696				},697			},698			Containers: []v1.Container{699				{700					Name:    createContainerName,701					Image:   imageutils.GetE2EImage(imageutils.Mounttest),702					Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volumes/create/data-1"},703					VolumeMounts: []v1.VolumeMount{704						{705							Name:      createVolumeName,706							MountPath: path.Join(volumeMountPath, "create"),707							ReadOnly:  true,708						},709					},710				},711			},712			RestartPolicy: v1.RestartPolicyNever,713		},714	}715	By("Creating the pod")716	pod = f.PodClient().Create(pod)717	return f.WaitForPodRunning(pod.Name)718}719func createNonOptionalConfigMapPodWithConfig(f *framework.Framework, volumeMountPath, podName string) error {720	podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)721	containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))722	falseValue := false723	createName := "cm-test-opt-create-" + string(uuid.NewUUID())724	createContainerName := "createcm-volume-test"725	createVolumeName := "createcm-volume"726	configMap := newConfigMap(f, createName)727	By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))728	var err error729	if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {730		framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)731	}732	//creating a pod with configMap object, but with different key which is not present in configMap object.733	pod := &v1.Pod{734		ObjectMeta: metav1.ObjectMeta{735			Name: podName,736		},737		Spec: v1.PodSpec{738			Volumes: []v1.Volume{739				{740					Name: createVolumeName,741					VolumeSource: v1.VolumeSource{742						ConfigMap: &v1.ConfigMapVolumeSource{743							LocalObjectReference: v1.LocalObjectReference{744								Name: createName,745							},746							Items: []v1.KeyToPath{747								{748									Key:  "data-4",749									Path: "path/to/data-4",750								},751							},752							Optional: &falseValue,753						},754					},755				},756			},757			Containers: []v1.Container{758				{759					Name:    createContainerName,760					Image:   imageutils.GetE2EImage(imageutils.Mounttest),761					Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/configmap-volumes/create/data-1"},762					VolumeMounts: []v1.VolumeMount{763						{764							Name:      createVolumeName,765							MountPath: path.Join(volumeMountPath, "create"),766							ReadOnly:  true,767						},768					},769				},770			},771			RestartPolicy: v1.RestartPolicyNever,772		},773	}774	By("Creating the pod")775	pod = f.PodClient().Create(pod)776	return f.WaitForPodRunning(pod.Name)777}...

projected_configmap.go

Source:projected_configmap.go

...110			},111		}112		ginkgo.By(fmt.Sprintf("Creating projection with configMap that has name %s", configMap.Name))113		var err error114		if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {115			framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)116		}117		pod := &v1.Pod{118			ObjectMeta: metav1.ObjectMeta{119				Name: "pod-projected-configmaps-" + string(uuid.NewUUID()),120			},121			Spec: v1.PodSpec{122				Volumes: []v1.Volume{123					{124						Name: volumeName,125						VolumeSource: v1.VolumeSource{126							Projected: &v1.ProjectedVolumeSource{127								Sources: []v1.VolumeProjection{128									{129										ConfigMap: &v1.ConfigMapProjection{130											LocalObjectReference: v1.LocalObjectReference{131												Name: name,132											},133										},134									},135								},136							},137						},138					},139				},140				Containers: []v1.Container{141					{142						Name:    containerName,143						Image:   imageutils.GetE2EImage(imageutils.Mounttest),144						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/projected-configmap-volume/data-1"},145						VolumeMounts: []v1.VolumeMount{146							{147								Name:      volumeName,148								MountPath: volumeMountPath,149								ReadOnly:  true,150							},151						},152					},153				},154				RestartPolicy: v1.RestartPolicyNever,155			},156		}157		ginkgo.By("Creating the pod")158		f.PodClient().CreateSync(pod)159		pollLogs := func() (string, error) {160			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, containerName)161		}162		gomega.Eventually(pollLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-1"))163		ginkgo.By(fmt.Sprintf("Updating configmap %v", configMap.Name))164		configMap.ResourceVersion = "" // to force update165		configMap.Data["data-1"] = "value-2"166		_, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Update(configMap)167		framework.ExpectNoError(err, "Failed to update configmap %q in namespace %q", configMap.Name, f.Namespace.Name)168		ginkgo.By("waiting to observe update in volume")169		gomega.Eventually(pollLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-2"))170	})171	/*172	   Release : v1.9173	   Testname: Projected Volume, ConfigMap, create, update and delete174	   Description: Create a Pod with three containers with ConfigMaps namely a create, update and delete container. Create Container when started MUST not have configMap, update and delete containers MUST be created with a ConfigMap value as âvalue-1â. Create a configMap in the create container, the Pod MUST be able to read the configMap from the create container. Update the configMap in the update container, Pod MUST be able to read the updated configMap value. Delete the configMap in the delete container. Pod MUST fail to read the configMap from the delete container.175	*/176	framework.ConformanceIt("optional updates should be reflected in volume [NodeConformance]", func() {177		podLogTimeout := framework.GetPodSecretUpdateTimeout(f.ClientSet)178		containerTimeoutArg := fmt.Sprintf("--retry_time=%v", int(podLogTimeout.Seconds()))179		trueVal := true180		volumeMountPath := "/etc/projected-configmap-volumes"181		deleteName := "cm-test-opt-del-" + string(uuid.NewUUID())182		deleteContainerName := "delcm-volume-test"183		deleteVolumeName := "deletecm-volume"184		deleteConfigMap := &v1.ConfigMap{185			ObjectMeta: metav1.ObjectMeta{186				Namespace: f.Namespace.Name,187				Name:      deleteName,188			},189			Data: map[string]string{190				"data-1": "value-1",191			},192		}193		updateName := "cm-test-opt-upd-" + string(uuid.NewUUID())194		updateContainerName := "updcm-volume-test"195		updateVolumeName := "updatecm-volume"196		updateConfigMap := &v1.ConfigMap{197			ObjectMeta: metav1.ObjectMeta{198				Namespace: f.Namespace.Name,199				Name:      updateName,200			},201			Data: map[string]string{202				"data-1": "value-1",203			},204		}205		createName := "cm-test-opt-create-" + string(uuid.NewUUID())206		createContainerName := "createcm-volume-test"207		createVolumeName := "createcm-volume"208		createConfigMap := &v1.ConfigMap{209			ObjectMeta: metav1.ObjectMeta{210				Namespace: f.Namespace.Name,211				Name:      createName,212			},213			Data: map[string]string{214				"data-1": "value-1",215			},216		}217		ginkgo.By(fmt.Sprintf("Creating configMap with name %s", deleteConfigMap.Name))218		var err error219		if deleteConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(deleteConfigMap); err != nil {220			framework.Failf("unable to create test configMap %s: %v", deleteConfigMap.Name, err)221		}222		ginkgo.By(fmt.Sprintf("Creating configMap with name %s", updateConfigMap.Name))223		if updateConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(updateConfigMap); err != nil {224			framework.Failf("unable to create test configMap %s: %v", updateConfigMap.Name, err)225		}226		pod := &v1.Pod{227			ObjectMeta: metav1.ObjectMeta{228				Name: "pod-projected-configmaps-" + string(uuid.NewUUID()),229			},230			Spec: v1.PodSpec{231				Volumes: []v1.Volume{232					{233						Name: deleteVolumeName,234						VolumeSource: v1.VolumeSource{235							Projected: &v1.ProjectedVolumeSource{236								Sources: []v1.VolumeProjection{237									{238										ConfigMap: &v1.ConfigMapProjection{239											LocalObjectReference: v1.LocalObjectReference{240												Name: deleteName,241											},242											Optional: &trueVal,243										},244									},245								},246							},247						},248					},249					{250						Name: updateVolumeName,251						VolumeSource: v1.VolumeSource{252							Projected: &v1.ProjectedVolumeSource{253								Sources: []v1.VolumeProjection{254									{255										ConfigMap: &v1.ConfigMapProjection{256											LocalObjectReference: v1.LocalObjectReference{257												Name: updateName,258											},259											Optional: &trueVal,260										},261									},262								},263							},264						},265					},266					{267						Name: createVolumeName,268						VolumeSource: v1.VolumeSource{269							Projected: &v1.ProjectedVolumeSource{270								Sources: []v1.VolumeProjection{271									{272										ConfigMap: &v1.ConfigMapProjection{273											LocalObjectReference: v1.LocalObjectReference{274												Name: createName,275											},276											Optional: &trueVal,277										},278									},279								},280							},281						},282					},283				},284				Containers: []v1.Container{285					{286						Name:    deleteContainerName,287						Image:   imageutils.GetE2EImage(imageutils.Mounttest),288						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/projected-configmap-volumes/delete/data-1"},289						VolumeMounts: []v1.VolumeMount{290							{291								Name:      deleteVolumeName,292								MountPath: path.Join(volumeMountPath, "delete"),293								ReadOnly:  true,294							},295						},296					},297					{298						Name:    updateContainerName,299						Image:   imageutils.GetE2EImage(imageutils.Mounttest),300						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/projected-configmap-volumes/update/data-3"},301						VolumeMounts: []v1.VolumeMount{302							{303								Name:      updateVolumeName,304								MountPath: path.Join(volumeMountPath, "update"),305								ReadOnly:  true,306							},307						},308					},309					{310						Name:    createContainerName,311						Image:   imageutils.GetE2EImage(imageutils.Mounttest),312						Command: []string{"/mounttest", "--break_on_expected_content=false", containerTimeoutArg, "--file_content_in_loop=/etc/projected-configmap-volumes/create/data-1"},313						VolumeMounts: []v1.VolumeMount{314							{315								Name:      createVolumeName,316								MountPath: path.Join(volumeMountPath, "create"),317								ReadOnly:  true,318							},319						},320					},321				},322				RestartPolicy: v1.RestartPolicyNever,323			},324		}325		ginkgo.By("Creating the pod")326		f.PodClient().CreateSync(pod)327		pollCreateLogs := func() (string, error) {328			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, createContainerName)329		}330		gomega.Eventually(pollCreateLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("Error reading file /etc/projected-configmap-volumes/create/data-1"))331		pollUpdateLogs := func() (string, error) {332			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, updateContainerName)333		}334		gomega.Eventually(pollUpdateLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("Error reading file /etc/projected-configmap-volumes/update/data-3"))335		pollDeleteLogs := func() (string, error) {336			return framework.GetPodLogs(f.ClientSet, f.Namespace.Name, pod.Name, deleteContainerName)337		}338		gomega.Eventually(pollDeleteLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-1"))339		ginkgo.By(fmt.Sprintf("Deleting configmap %v", deleteConfigMap.Name))340		err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Delete(deleteConfigMap.Name, &metav1.DeleteOptions{})341		framework.ExpectNoError(err, "Failed to delete configmap %q in namespace %q", deleteConfigMap.Name, f.Namespace.Name)342		ginkgo.By(fmt.Sprintf("Updating configmap %v", updateConfigMap.Name))343		updateConfigMap.ResourceVersion = "" // to force update344		delete(updateConfigMap.Data, "data-1")345		updateConfigMap.Data["data-3"] = "value-3"346		_, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Update(updateConfigMap)347		framework.ExpectNoError(err, "Failed to update configmap %q in namespace %q", updateConfigMap.Name, f.Namespace.Name)348		ginkgo.By(fmt.Sprintf("Creating configMap with name %s", createConfigMap.Name))349		if createConfigMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(createConfigMap); err != nil {350			framework.Failf("unable to create test configMap %s: %v", createConfigMap.Name, err)351		}352		ginkgo.By("waiting to observe update in volume")353		gomega.Eventually(pollCreateLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-1"))354		gomega.Eventually(pollUpdateLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("value-3"))355		gomega.Eventually(pollDeleteLogs, podLogTimeout, framework.Poll).Should(gomega.ContainSubstring("Error reading file /etc/projected-configmap-volumes/delete/data-1"))356	})357	/*358	   Release : v1.9359	   Testname: Projected Volume, ConfigMap, multiple volume paths360	   Description: A Pod is created with a projected volume source âConfigMapâ to store a configMap. The configMap is mapped to two different volume mounts. Pod MUST be able to read the content of the configMap successfully from the two volume mounts.361	*/362	framework.ConformanceIt("should be consumable in multiple volumes in the same pod [NodeConformance]", func() {363		var (364			name             = "projected-configmap-test-volume-" + string(uuid.NewUUID())365			volumeName       = "projected-configmap-volume"366			volumeMountPath  = "/etc/projected-configmap-volume"367			volumeName2      = "projected-configmap-volume-2"368			volumeMountPath2 = "/etc/projected-configmap-volume-2"369			configMap        = newConfigMap(f, name)370		)371		ginkgo.By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))372		var err error373		if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {374			framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)375		}376		pod := &v1.Pod{377			ObjectMeta: metav1.ObjectMeta{378				Name: "pod-projected-configmaps-" + string(uuid.NewUUID()),379			},380			Spec: v1.PodSpec{381				Volumes: []v1.Volume{382					{383						Name: volumeName,384						VolumeSource: v1.VolumeSource{385							Projected: &v1.ProjectedVolumeSource{386								Sources: []v1.VolumeProjection{387									{388										ConfigMap: &v1.ConfigMapProjection{389											LocalObjectReference: v1.LocalObjectReference{390												Name: name,391											},392										},393									},394								},395							},396						},397					},398					{399						Name: volumeName2,400						VolumeSource: v1.VolumeSource{401							Projected: &v1.ProjectedVolumeSource{402								Sources: []v1.VolumeProjection{403									{404										ConfigMap: &v1.ConfigMapProjection{405											LocalObjectReference: v1.LocalObjectReference{406												Name: name,407											},408										},409									},410								},411							},412						},413					},414				},415				Containers: []v1.Container{416					{417						Name:  "projected-configmap-volume-test",418						Image: imageutils.GetE2EImage(imageutils.Mounttest),419						Args:  []string{"--file_content=/etc/projected-configmap-volume/data-1"},420						VolumeMounts: []v1.VolumeMount{421							{422								Name:      volumeName,423								MountPath: volumeMountPath,424								ReadOnly:  true,425							},426							{427								Name:      volumeName2,428								MountPath: volumeMountPath2,429								ReadOnly:  true,430							},431						},432					},433				},434				RestartPolicy: v1.RestartPolicyNever,435			},436		}437		f.TestContainerOutput("consume configMaps", pod, 0, []string{438			"content of file \"/etc/projected-configmap-volume/data-1\": value-1",439		})440	})441	//The pod is in pending during volume creation until the configMap objects are available442	//or until mount the configMap volume times out. There is no configMap object defined for the pod, so it should return timout exception unless it is marked optional.443	//Slow (~5 mins)444	ginkgo.It("Should fail non-optional pod creation due to configMap object does not exist [Slow]", func() {445		volumeMountPath := "/etc/projected-configmap-volumes"446		podName := "pod-projected-configmaps-" + string(uuid.NewUUID())447		err := createNonOptionalConfigMapPod(f, volumeMountPath, podName)448		framework.ExpectError(err, "created pod %q with non-optional configMap in namespace %q", podName, f.Namespace.Name)449	})450	//ConfigMap object defined for the pod, If a key is specified which is not present in the ConfigMap,451	// the volume setup will error unless it is marked optional, during the pod creation.452	//Slow (~5 mins)453	ginkgo.It("Should fail non-optional pod creation due to the key in the configMap object does not exist [Slow]", func() {454		volumeMountPath := "/etc/configmap-volumes"455		podName := "pod-configmaps-" + string(uuid.NewUUID())456		err := createNonOptionalConfigMapPodWithConfig(f, volumeMountPath, podName)457		framework.ExpectError(err, "created pod %q with non-optional configMap in namespace %q", podName, f.Namespace.Name)458	})459})460func doProjectedConfigMapE2EWithoutMappings(f *framework.Framework, uid, fsGroup int64, defaultMode *int32) {461	userID := int64(uid)462	groupID := int64(fsGroup)463	var (464		name            = "projected-configmap-test-volume-" + string(uuid.NewUUID())465		volumeName      = "projected-configmap-volume"466		volumeMountPath = "/etc/projected-configmap-volume"467		configMap       = newConfigMap(f, name)468	)469	ginkgo.By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))470	var err error471	if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {472		framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)473	}474	pod := &v1.Pod{475		ObjectMeta: metav1.ObjectMeta{476			Name: "pod-projected-configmaps-" + string(uuid.NewUUID()),477		},478		Spec: v1.PodSpec{479			SecurityContext: &v1.PodSecurityContext{},480			Volumes: []v1.Volume{481				{482					Name: volumeName,483					VolumeSource: v1.VolumeSource{484						Projected: &v1.ProjectedVolumeSource{485							Sources: []v1.VolumeProjection{486								{487									ConfigMap: &v1.ConfigMapProjection{488										LocalObjectReference: v1.LocalObjectReference{489											Name: name,490										},491									},492								},493							},494						},495					},496				},497			},498			Containers: []v1.Container{499				{500					Name:  "projected-configmap-volume-test",501					Image: imageutils.GetE2EImage(imageutils.Mounttest),502					Args: []string{503						"--file_content=/etc/projected-configmap-volume/data-1",504						"--file_mode=/etc/projected-configmap-volume/data-1"},505					VolumeMounts: []v1.VolumeMount{506						{507							Name:      volumeName,508							MountPath: volumeMountPath,509						},510					},511				},512			},513			RestartPolicy: v1.RestartPolicyNever,514		},515	}516	if userID != 0 {517		pod.Spec.SecurityContext.RunAsUser = &userID518	}519	if groupID != 0 {520		pod.Spec.SecurityContext.FSGroup = &groupID521	}522	if defaultMode != nil {523		//pod.Spec.Volumes[0].VolumeSource.Projected.Sources[0].ConfigMap.DefaultMode = defaultMode524		pod.Spec.Volumes[0].VolumeSource.Projected.DefaultMode = defaultMode525	}526	fileModeRegexp := framework.GetFileModeRegex("/etc/projected-configmap-volume/data-1", defaultMode)527	output := []string{528		"content of file \"/etc/projected-configmap-volume/data-1\": value-1",529		fileModeRegexp,530	}531	f.TestContainerOutputRegexp("consume configMaps", pod, 0, output)532}533func doProjectedConfigMapE2EWithMappings(f *framework.Framework, uid, fsGroup int64, itemMode *int32) {534	userID := int64(uid)535	groupID := int64(fsGroup)536	var (537		name            = "projected-configmap-test-volume-map-" + string(uuid.NewUUID())538		volumeName      = "projected-configmap-volume"539		volumeMountPath = "/etc/projected-configmap-volume"540		configMap       = newConfigMap(f, name)541	)542	ginkgo.By(fmt.Sprintf("Creating configMap with name %s", configMap.Name))543	var err error544	if configMap, err = f.ClientSet.CoreV1().ConfigMaps(f.Namespace.Name).Create(configMap); err != nil {545		framework.Failf("unable to create test configMap %s: %v", configMap.Name, err)546	}547	pod := &v1.Pod{548		ObjectMeta: metav1.ObjectMeta{549			Name: "pod-projected-configmaps-" + string(uuid.NewUUID()),550		},551		Spec: v1.PodSpec{552			SecurityContext: &v1.PodSecurityContext{},553			Volumes: []v1.Volume{554				{555					Name: volumeName,556					VolumeSource: v1.VolumeSource{557						Projected: &v1.ProjectedVolumeSource{558							Sources: []v1.VolumeProjection{...

Create

Using AI Code Generation

1import (2func main() {3	config, err := rest.InClusterConfig()4	if err != nil {5		panic(err.Error())6	}7	clientset, err := kubernetes.NewForConfig(config)8	if err != nil {9		panic(err.Error())10	}11	configmap, err := clientset.CoreV1().ConfigMaps("default").Create(context.TODO(), &v1.ConfigMap{12		ObjectMeta: metav1.ObjectMeta{13		},14		Data: map[string]string{15		},16	}, metav1.CreateOptions{})17	if err != nil {18		panic(err.Error())19	}20	fmt.Printf("Configmap created")21}22import (23func main() {24	config, err := rest.InClusterConfig()25	if err != nil {26		panic(err.Error())27	}28	clientset, err := kubernetes.NewForConfig(config)29	if err != nil {30		panic(err.Error())31	}32	configmap, err := clientset.CoreV1().ConfigMaps("default").Get(context.TODO(), "my-config", metav1.GetOptions{})33	if err != nil {34		panic(err.Error())35	}36	fmt.Printf("Configmap data: %v", configmap.Data)37}38import (39func main() {

Create

Using AI Code Generation

1import (2func main() {3	config, err := rest.InClusterConfig()4	if err != nil {5		if config, err = clientcmd.BuildConfigFromFlags("", os.Getenv("HOME")+"/.kube/config"); err != nil {6			panic(err.Error())7		}8	}9	clientset, err := kubernetes.NewForConfig(config)10	if err != nil {11		panic(err.Error())12	}13	configmap := &v1.ConfigMap{14		ObjectMeta: metav1.ObjectMeta{15		},16		Data: map[string]string{17		},18	}19	fmt.Println("Creating configmap...")20	result, err := clientset.CoreV1().ConfigMaps(namespace).Create(configmap)21	if err != nil {22		panic(err)23	}24	fmt.Printf("Created configmap %q.\n", result.GetObjectMeta().GetName())25}26import (27func main() {28	config, err := rest.InClusterConfig()29	if err != nil {30		if config, err = clientcmd.BuildConfigFromFlags("", os.Getenv("HOME")+"/.kube/config"); err != nil {31			panic(err.Error())32		}33	}34	clientset, err := kubernetes.NewForConfig(config)35	if err != nil {

Create

Using AI Code Generation

1import (2func main() {3	kubeconfig := filepath.Join(4		os.Getenv("HOME"), ".kube", "config",5	config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)6	if err != nil {7		panic(err.Error())8	}9	clientset, err := kubernetes.NewForConfig(config)10	if err != nil {11		panic(err.Error())12	}13	configmap := &v1.ConfigMap{14		ObjectMeta: metav1.ObjectMeta{15		},16		Data: map[string]string{17		},18	}19	fmt.Println("Creating configmap...")20	result, err := clientset.CoreV1().ConfigMaps("default").Create(configmap)21	if err != nil {22		panic(err)23	}24	fmt.Printf("Created configmap %q.\n", result.GetObjectMeta().GetName())25}26import (27func main() {28	kubeconfig := filepath.Join(29		os.Getenv("HOME"), ".kube", "config",30	config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)31	if err != nil {32		panic(err.Error())33	}34	clientset, err := kubernetes.NewForConfig(config)35	if err != nil {

Create

Using AI Code Generation

1import (2func main() {3        if home := homedir.HomeDir(); home != "" {4                kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")5        } else {6                kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")7        }8        flag.Parse()9        config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)10        if err != nil {11                panic(err.Error())12        }13        clientset, err := kubernetes.NewForConfig(config)14        if err != nil {15                panic(err.Error())16        }17        cm := &v1.ConfigMap{18                ObjectMeta: metav1.ObjectMeta{19                },20                Data: map[string]string{21                },22        }23        _, err = clientset.CoreV1().ConfigMaps("default").Create(cm)24        if err != nil {25                panic(err.Error())26        }27        fmt.Println("Created ConfigMap")28}29import (30func main() {31        if home := homedir.HomeDir(); home != "" {32                kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config

Create

Using AI Code Generation

1    fmt.Println("Creating configmap...")2    configMap := &v1.ConfigMap{3        ObjectMeta: metav1.ObjectMeta{4        },5        Data: map[string]string{6        },7    }8    result, err := clientset.CoreV1().ConfigMaps("default").Create(configMap)9    if err != nil {10        panic(err.Error())11    }12    fmt.Printf("Created configmap %q.\n", result.GetObjectMeta().GetName())13}

Create

Using AI Code Generation

1import (2func main() {3	if home := homedir.HomeDir(); home != "" {4		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")5	} else {6		kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")7	}8	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)9	if err != nil {10		panic(err.Error())11	}12	clientset, err := kubernetes.NewForConfig(config)13	if err != nil {14		panic(err.Error())15	}16	configmap, err := clientset.CoreV1().ConfigMaps("default").Create(context.TODO(), &v1.ConfigMap{17		ObjectMeta: metav1.ObjectMeta{18		},19		Data: map[string]string{20		},21	}, metav1.CreateOptions{})22	if err != nil {23		panic(err.Error())24	}25	fmt.Printf("Created configmap %q.\n", configmap.GetObjectMeta().GetName())26}27import (28func main() {29	if home := homedir.HomeDir(); home != "" {30		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")31	} else {

Create

Using AI Code Generation

1import (2func main() {3	filepath.Walk(".", func(path string, info os.FileInfo, err error) error {4		if strings.Contains(path, ".go") {5			fmt.Println(path)6			time.Sleep(1 * time.Second)7		}8	})9}10import (11func main() {12	filepath.Walk(".", func(path string, info os.FileInfo, err error) error {13		if strings.Contains(path, ".go") {14			fmt.Println(path)15			time.Sleep(1 * time.Second)16		}17	})18}19import (20func main() {21	filepath.Walk(".", func(path string, info os.FileInfo, err error) error {22		if strings.Contains(path, ".go") {23			fmt.Println(path)24			time.Sleep(1 * time.Second)25		}26	})27}28import (29func main() {30	filepath.Walk(".", func(path string, info os.FileInfo, err error) error {31		if strings.Contains(path, ".go") {32			fmt.Println(path)33			time.Sleep(1 * time.Second)34		}35	})36}37import (38func main() {39	filepath.Walk(".", func(path string, info os.FileInfo, err error) error {40		if strings.Contains(path, ".go") {41			fmt.Println(path)42			time.Sleep(1 * time.Second)43		}44	})45}46import (

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.