Added dirsToCreate (#24)

Author: urihoenig

pkg/flex/mounter.go

@@ -53,9 +53,42 @@ func (m *Mounter) Mount(targetPath string, specString string) *Response {
 		return NewFailResponse("Failed to create v3io FUSE container", err)
 	}
 
+	if err := m.createDirs(spec, targetPath); err != nil {
+		return NewFailResponse("Failed to create folders", err)
+	}
+
 	return NewSuccessResponse("Successfully mounted")
 }
 
+func (m *Mounter) createDirs(spec Spec, targetPath string) error {
+	var dirsToCreate []DirToCreate
+	if err := json.Unmarshal([]byte(spec.DirsToCreate), &dirsToCreate); err != nil {
+		return fmt.Errorf("Failed to parse dirsToCreate [%s]: %s", spec.DirsToCreate, err.Error())
+	}
+	for _, dir := range dirsToCreate {
+		if strings.HasPrefix(dir.Name, "/") {
+			return fmt.Errorf("Only creation of relative path is supported (%s)", dir.Name)
+		}
+		dirToCreate := fmt.Sprintf("%s/%s", targetPath, dir.Name)
+
+		_, err := os.Stat(dirToCreate)
+		if err == nil {
+			journal.Debug(fmt.Sprintf("Folder already exists: %s", dirToCreate))
+			continue
+		}
+
+		if !os.IsNotExist(err) {
+			return fmt.Errorf("Stat failed for folder [%s]: %s", dirToCreate, err)
+		}
+
+		if err := os.MkdirAll(dirToCreate, dir.Permissions); err != nil {
+			return fmt.Errorf("Failed to create folder (path: %s, filemode: %o): %s", dir.Name, dir.Permissions, err.Error())
+		}
+		journal.Debug(fmt.Sprintf("Created folder: %s", dirToCreate))
+	}
+	return nil
+}
+
 func (m *Mounter) Unmount(targetPath string) *Response {
 	journal.Debug("Unmounting")
 

pkg/flex/spec.go

@@ -3,8 +3,14 @@ package flex
 import (
 	"encoding/base64"
 	"errors"
+	"os"
 )
 
+type DirToCreate struct {
+	Name              string `json:"name"`
+	Permissions       os.FileMode `json:"permissions"`
+}
+
 type Spec struct {
 	SubPath           string `json:"subPath"`
 	Container         string `json:"container"`
@@ -14,6 +20,7 @@ type Spec struct {
 	PodName           string `json:"kubernetes.io/pod.name"`
 	Namespace         string `json:"kubernetes.io/pod.namespace"`
 	Name              string `json:"kubernetes.io/pvOrVolumeName"`
+	DirsToCreate      string `json:"dirsToCreate"`
 }
 
 func (s *Spec) decodeOrDefault(value string) string {