Add ganesha nfs server

Signed-off-by: Roman Mohr <[email protected]>

Author: rmohr

cmd/run.go

@@ -13,6 +13,7 @@ import (
 	"io"
 	"os"
 	"os/signal"
+	"path/filepath"
 	"strconv"
 	"sync"
 )
@@ -73,6 +74,11 @@ func run(cmd *cobra.Command, args []string) error {
 		return err
 	}
 
+	nfs_data, err := cmd.Flags().GetString("nfs-data")
+	if err != nil {
+		return err
+	}
+
 	cluster := args[0]
 
 	background, err := cmd.Flags().GetBool("background")
@@ -160,7 +166,7 @@ func run(cmd *cobra.Command, args []string) error {
 		}
 		registryMounts = []mount.Mount{
 			{
-				Type:   "volume",
+				Type:   mount.TypeVolume,
 				Source: vol.Name,
 				Target: "/var/lib/registry",
 			},
@@ -182,6 +188,41 @@ func run(cmd *cobra.Command, args []string) error {
 		return err
 	}
 
+	if nfs_data != "" {
+		nfs_data, err := filepath.Abs(nfs_data)
+		if err != nil {
+			return err
+		}
+		// Pull the ganesha image
+		reader, err = cli.ImagePull(ctx, "docker.io/janeczku/nfs-ganesha", types.ImagePullOptions{})
+		if err != nil {
+			panic(err)
+		}
+		io.Copy(os.Stdout, reader)
+
+		// Start the ganesha image
+		nfsServer, err := cli.ContainerCreate(ctx, &container.Config{
+			Image: "janeczku/nfs-ganesha",
+		}, &container.HostConfig{
+			Mounts: []mount.Mount{
+				{
+					Type:   mount.TypeBind,
+					Source: nfs_data,
+					Target: "/data/nfs",
+				},
+			},
+			Privileged:  true,
+			NetworkMode: container.NetworkMode("container:" + dnsmasq.ID),
+		}, nil, prefix+"-nfs-ganesha")
+		if err != nil {
+			return err
+		}
+		createdContainers = append(createdContainers, nfsServer.ID)
+		if err := cli.ContainerStart(ctx, nfsServer.ID, types.ContainerStartOptions{}); err != nil {
+			return err
+		}
+	}
+
 	wg := sync.WaitGroup{}
 	wg.Add(int(nodes))
 	// start one vm after each other