Add a property to Mount trait that creates then mounts a PVC

pkg/trait/mount.go

@@ -52,6 +52,8 @@ type mountTrait struct {
 	Resources []string `property:"resources" json:"resources,omitempty"`
 	// A list of Persistent Volume Claims to be mounted. Syntax: [pvcname:/container/path]
 	Volumes []string `property:"volumes" json:"volumes,omitempty"`
+	// A list of Persistent Volume Claims to be created and mounted. Syntax: [pvcname:storageClassName:requestedQuantity:/container/path]
+	PVCs []string `property:"pvcs" json:"pvcs,omitempty"`
 }
 
 func newMountTrait() Trait {
@@ -163,6 +165,14 @@ func (t *mountTrait) configureVolumesAndMounts(e *Environment, vols *[]corev1.Vo
 			return parseErr
 		}
 	}
+	for _, p := range t.PVCs {
+		if pvc, vol, createAndParseErr := utilResource.CreateAndParseVolume(p); createAndParseErr == nil {
+			e.Resources.Add(pvc)
+			t.mountResource(vols, mnts, vol)
+		} else {
+			return createAndParseErr
+		}
+	}
 
 	return nil
 }

pkg/util/resource/config.go

@@ -30,6 +30,8 @@ import (
 	"github.com/apache/camel-k/pkg/util/kubernetes"
 	corev1 "k8s.io/api/core/v1"
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
+	"k8s.io/apimachinery/pkg/api/resource"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
 // Config represents a config option.
@@ -170,6 +172,37 @@ func ParseVolume(item string) (*Config, error) {
 	}, nil
 }
 
+// CreateAndParseVolume will create and parse a volume then return the created volume and a Config.
+func CreateAndParseVolume(item string) (*corev1.PersistentVolumeClaim, *Config, error) {
+	pvcParts := strings.Split(item, ":")
+
+	if len(pvcParts) != 4 {
+		return nil, nil, fmt.Errorf("could not create and mount pvc as %s", item)
+	}
+
+	return &corev1.PersistentVolumeClaim{
+			TypeMeta: metav1.TypeMeta{
+				Kind:       "PersistentVolumeClaim",
+				APIVersion: "v1",
+			},
+			ObjectMeta: metav1.ObjectMeta{
+				Name: pvcParts[0],
+			},
+			Spec: corev1.PersistentVolumeClaimSpec{
+				StorageClassName: &pvcParts[1],
+				Resources: corev1.ResourceRequirements{
+					Requests: corev1.ResourceList{
+						"storage": resource.MustParse(pvcParts[2]),
+					},
+				},
+			},
+		}, &Config{
+			storageType:     StorageTypePVC,
+			resourceName:    pvcParts[0],
+			destinationPath: pvcParts[3],
+		}, nil
+}
+
 // ParseConfig will parse a config and return a Config.
 func ParseConfig(item string) (*Config, error) {
 	return parse(item, ContentTypeText)