suppor nfs volume

api/helpers.go

@@ -11,6 +11,10 @@ func (v *VolumeDescription) IsDir() bool {
 	return v.Format == "vfs"
 }
 
+func (v *VolumeDescription) IsNas() bool {
+	return v.Format == "nas"
+}
+
 func SandboxInfoFromOCF(s *specs.Spec) *SandboxConfig {
 	return &SandboxConfig{
 		Hostname: s.Hostname,

hypervisor/context.go

@@ -378,8 +378,8 @@ func (ctx *VmContext) AddVolume(vol *api.VolumeDescription, result chan api.Resu
 
 	dc := NewDiskContext(ctx, vol)
 
-	if vol.IsDir() {
-		ctx.Log(INFO, "return volume add success for dir %s", vol.Name)
+	if vol.IsDir() || vol.IsNas() {
+		ctx.Log(INFO, "return volume add success for dir/nas %s", vol.Name)
 		result <- api.NewResultBase(vol.Name, true, "")
 	} else {
 		ctx.Log(DEBUG, "insert disk for volume %s", vol.Name)

hypervisor/disk.go

@@ -3,9 +3,10 @@ package hypervisor
 import (
 	"sync"
 
-	"github.com/hyperhq/runv/api"
 	"strconv"
 	"strings"
+
+	"github.com/hyperhq/runv/api"
 )
 
 type DiskDescriptor struct {
@@ -24,6 +25,10 @@ func (d *DiskDescriptor) IsDir() bool {
 	return d.Format == "vfs"
 }
 
+func (d *DiskDescriptor) IsNas() bool {
+	return d.Format == "nas"
+}
+
 type DiskContext struct {
 	*DiskDescriptor
 
@@ -49,6 +54,9 @@ func NewDiskContext(ctx *VmContext, vol *api.VolumeDescription) *DiskContext {
 	}
 	if vol.IsDir() {
 		dc.ready = true
+	} else if vol.IsNas() {
+		dc.DeviceName = vol.Source
+		dc.ready = true
 	} else if vol.Format == "rbd" {
 		dc.Options = map[string]string{
 			"user":        vol.Options.User,
@@ -107,7 +115,7 @@ func (dc *DiskContext) remove(result chan<- api.Result) {
 		result = make(chan api.Result, 4)
 	}
 
-	if dc.IsDir() {
+	if dc.IsDir() || dc.IsNas() {
 		result <- api.NewResultBase(dc.Name, true, "no need to unplug")
 		return
 	}