feat(controller-sdk-go): drycc run cmd add --mount para

Author: lijianguo

.gitignore

@@ -25,3 +25,4 @@ _testmain.go
 
 vendor
 coverage.txt
+.idea/*

api/apps.go

@@ -29,6 +29,7 @@ type AppUpdateRequest struct {
 // AppRunRequest is the definition of POST /v2/apps/<app id>/run.
 type AppRunRequest struct {
 	Command string `json:"command"`
+	Volumes map[string]interface{} `json:"volumes,omitempty"`
 }
 
 // AppRunResponse is the definition of /v2/apps/<app id>/run.

api/volumes.go

@@ -0,0 +1,34 @@
+package api
+
+// Mount is the definition of PATCH /v2/apps/<app_id>/volumes/<name>/path/.
+type Mount struct {
+	Values map[string]string `json:"values"`
+}
+
+// Unmount is the definition of PATCH /v2/apps/<app_id>/volumes/<name>/path/.
+type Unmount struct {
+	Values map[string]interface{} `json:"values"`
+}
+
+// Volume is the structure of an app's volume.
+type Volume struct {
+	// Owner is the app owner.
+	Owner string `json:"owner,omitempty"`
+	// App is the app the tls settings apply to and cannot be updated.
+	App string `json:"app,omitempty"`
+	// Created is the time that the volume was created and cannot be updated.
+	Created string `json:"created,omitempty"`
+	// Updated is the last time the TLS settings was changed and cannot be updated.
+	Updated string `json:"updated,omitempty"`
+	// UUID is a unique string reflecting the volume in its current state.
+	// It changes every time the volume is changed and cannot be updated.
+	UUID string `json:"uuid,omitempty"`
+	// Volume's name
+	Name string `json:"name,omitempty"`
+	//Volume's size
+	Size string `json:"size,omitempty"`
+	// mount application's path
+	Path map[string]interface{} `json:"path,omitempty"`
+}
+
+type Volumes []Volume

apps/apps.go

@@ -112,8 +112,11 @@ func Logs(c *drycc.Client, appID string, lines int) (string, error) {
 
 // Run a one-time command in your app. This will start a kubernetes job with the
 // same container image and environment as the rest of the app.
-func Run(c *drycc.Client, appID string, command string) (api.AppRunResponse, error) {
-	req := api.AppRunRequest{Command: command}
+func Run(c *drycc.Client, appID string, command string, volumes map[string]interface{}) (api.AppRunResponse, error) {
+	req := api.AppRunRequest{
+		Command: command,
+		Volumes: volumes,
+	}
 	body, err := json.Marshal(req)
 
 	if err != nil {

apps/apps_test.go

@@ -252,7 +252,7 @@ func TestAppsRun(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	actual, err := Run(drycc, "example-go", "echo hi")
+	actual, err := Run(drycc, "example-go", "echo hi", nil)
 
 	if err != nil {
 		t.Fatal(err)

volumes/volumes.go

@@ -0,0 +1,81 @@
+// Package config provides methods for managing configuration of apps.
+package volumes
+
+import (
+	"encoding/json"
+	"fmt"
+
+	drycc "github.com/drycc/controller-sdk-go"
+	"github.com/drycc/controller-sdk-go/api"
+)
+
+// List list an app's volumes.
+func List(c *drycc.Client, appID string, results int) (api.Volumes, int, error) {
+	u := fmt.Sprintf("/v2/apps/%s/volumes/", appID)
+	body, count, reqErr := c.LimitedRequest(u, results)
+	if reqErr != nil && !drycc.IsErrAPIMismatch(reqErr) {
+		return []api.Volume{}, -1, reqErr
+	}
+	var volumes []api.Volume
+	if err := json.Unmarshal([]byte(body), &volumes); err != nil {
+		return []api.Volume{}, -1, err
+	}
+	return volumes, count, reqErr
+}
+
+// Create create an app's Volume.
+func Create(c *drycc.Client, appID string, volume api.Volume) (api.Volume, error) {
+	body, err := json.Marshal(volume)
+	if err != nil {
+		return api.Volume{}, err
+	}
+	u := fmt.Sprintf("/v2/apps/%s/volumes/", appID)
+	res, reqErr := c.Request("POST", u, body)
+	if reqErr != nil {
+		return api.Volume{}, reqErr
+	}
+	defer res.Body.Close()
+	newVolume := api.Volume{}
+	if err = json.NewDecoder(res.Body).Decode(&newVolume); err != nil {
+		return api.Volume{}, err
+	}
+	return newVolume, reqErr
+}
+
+// Delete delete an app's Volume.
+func Delete(c *drycc.Client, appID string, name string) error {
+	u := fmt.Sprintf("/v2/apps/%s/volumes/%s/", appID, name)
+	res, err := c.Request("DELETE", u, nil)
+	if err == nil {
+		res.Body.Close()
+	}
+	return err
+}
+
+// Mount mount an app's volume and creates a new release.
+// This is a patching operation, which means when you call Mount() with an api.Volumes:
+//
+//    - If the variable does not exist, it will be set.
+//    - If the variable exists, it will be overwritten.
+//    - If the variable is set to nil, it will be unmount.
+//    - If the variable was ignored in the api.Volumes, it will remain unchanged.
+//
+// Calling Mount() with an empty api.Volume will return a drycc.ErrConflict.
+// Trying to Unmount a key that does not exist returns a drycc.ErrUnprocessable.
+func Mount(c *drycc.Client, appID string, name string, volume api.Volume) (api.Volume, error) {
+	body, err := json.Marshal(volume)
+	if err != nil {
+		return api.Volume{}, err
+	}
+	u := fmt.Sprintf("/v2/apps/%s/volumes/%s/path/", appID, name)
+	res, reqErr := c.Request("PATCH", u, body)
+	if reqErr != nil {
+		return api.Volume{}, reqErr
+	}
+	defer res.Body.Close()
+	newVolume := api.Volume{}
+	if err = json.NewDecoder(res.Body).Decode(&newVolume); err != nil {
+		return api.Volume{}, err
+	}
+	return newVolume, reqErr
+}