Function createPVC

pkg/devspace/services/podreplace/replace.go:299–359

(ctx devspacecontext.Context, deployment *appsv1.Deployment, devPod *latest.DevPod)

}

func createPVC(ctx devspacecontext.Context, deployment *appsv1.Deployment, devPod *latest.DevPod) error {
	var err error
	size := resource.MustParse("10Gi")
	if devPod.PersistenceOptions != nil && devPod.PersistenceOptions.Size != "" {
		size, err = resource.ParseQuantity(devPod.PersistenceOptions.Size)
		if err != nil {
			return fmt.Errorf("error parsing persistent volume size %s: %v", devPod.PersistenceOptions.Size, err)
		}
	}

	var storageClassName *string
	if devPod.PersistenceOptions != nil && devPod.PersistenceOptions.StorageClassName != "" {
		storageClassName = &devPod.PersistenceOptions.StorageClassName
	}

	accessModes := []corev1.PersistentVolumeAccessMode{corev1.ReadWriteOnce}
	if devPod.PersistenceOptions != nil && devPod.PersistenceOptions.AccessModes != nil {
		accessModes = []corev1.PersistentVolumeAccessMode{}
		for _, accessMode := range devPod.PersistenceOptions.AccessModes {
			accessModes = append(accessModes, corev1.PersistentVolumeAccessMode(accessMode))
		}
	}

	name := getClaimName(deployment, devPod)

	_, err = ctx.KubeClient().KubeClient().CoreV1().PersistentVolumeClaims(deployment.Namespace).Create(ctx.Context(), &corev1.PersistentVolumeClaim{
		ObjectMeta: metav1.ObjectMeta{
			Name:      name,
			Namespace: deployment.Namespace,
			OwnerReferences: []metav1.OwnerReference{
				{
					APIVersion: appsv1.SchemeGroupVersion.String(),
					Kind:       "Deployment",
					Name:       deployment.Name,
					UID:        deployment.UID,
					Controller: ptr.Bool(true),
				},
			},
		},
		Spec: corev1.PersistentVolumeClaimSpec{
			AccessModes: accessModes,
			Resources: corev1.VolumeResourceRequirements{
				Requests: map[corev1.ResourceName]resource.Quantity{
					corev1.ResourceStorage: size,
				},
			},
			StorageClassName: storageClassName,
		},
	}, metav1.CreateOptions{})
	if err != nil {
		if kerrors.IsAlreadyExists(err) {
			ctx.Log().Debugf("PVC %s already exists for replaced pod %s", name, deployment.Name)
			return nil
		}

		return err
	}