Merge pull request #13 from vieux/add_port

Add port

Author: vieux

README.md

@@ -15,7 +15,7 @@ $ docker plugin install vieux/sshfs # or docker plugin install vieux/sshfs DEBUG
 2 - Create a volume
 
 ```
-$ docker volume create -d vieux/sshfs -o sshcmd=<user@host:path> -o password=<password> sshvolume
+$ docker volume create -d vieux/sshfs -o sshcmd=<user@host:path> -o password=<password> [-o port=<port>] sshvolume
 sshvolume
 $ docker volume ls
 DRIVER              VOLUME NAME

main.go

@@ -21,6 +21,7 @@ const socketAddress = "/run/docker/plugins/sshfs.sock"
 type sshfsVolume struct {
 	Password string
 	Sshcmd   string
+	Port     string
 
 	Mountpoint  string
 	connections int
@@ -77,11 +78,23 @@ func (d *sshfsDriver) Create(r volume.Request) volume.Response {
 	d.Lock()
 	defer d.Unlock()
 	v := &sshfsVolume{}
-	if r.Options == nil || r.Options["sshcmd"] == "" {
-		return responseError("ssh option required")
+
+	for key, val := range r.Options {
+		switch key {
+		case "sshcmd":
+			v.Sshcmd = val
+		case "password":
+			v.Password = val
+		case "port":
+			v.Port = val
+		default:
+			return responseError(fmt.Sprintf("unknown option %q", val))
+		}
+	}
+
+	if v.Sshcmd == "" {
+		return responseError("'sshcmd' option required")
 	}
-	v.Sshcmd = r.Options["sshcmd"]
-	v.Password = r.Options["password"]
 	v.Mountpoint = filepath.Join(d.root, fmt.Sprintf("%x", md5.Sum([]byte(v.Sshcmd))))
 
 	d.volumes[r.Name] = v
@@ -219,6 +232,9 @@ func (d *sshfsDriver) Capabilities(r volume.Request) volume.Response {
 
 func (d *sshfsDriver) mountVolume(v *sshfsVolume) error {
 	cmd := fmt.Sprintf("sshfs -oStrictHostKeyChecking=no %s %s", v.Sshcmd, v.Mountpoint)
+	if v.Port != "" {
+		cmd = fmt.Sprintf("%s -p %s", cmd, v.Port)
+	}
 	if v.Password != "" {
 		cmd = fmt.Sprintf("echo %s | %s -o workaround=rename -o password_stdin", v.Password, cmd)
 	}