feat(controller):add drycc resource cmd

Author: lijianguo

api/apps.go

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

api/resource.go

@@ -0,0 +1,35 @@
+package api
+
+// Binding is the definition of PATCH /v2/apps/<app_id>/resources/<name>/binding/.
+type Binding struct {
+	BindAction string `json:"bind_action,omitempty"`
+}
+
+// Resource is the structure of an app's resource.
+type Resource 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 resource 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 resource in its current state.
+	// It changes every time the resource is changed and cannot be updated.
+	UUID string `json:"uuid,omitempty,-"`
+	// Resource's name
+	Name string `json:"name,omitempty"`
+	// Resource's Plan
+	Plan string `json:"plan,omitempty"`
+	// Resource connet info
+	Data map[string]interface{} `json:"data,omitempty"`
+	// Resource's status
+	Status string `json:"status,omitempty"`
+	// Resource's binding status
+	Binding string `json:"binding,omitempty"`
+	// Resource Options
+	Options map[string]interface{} `json:"options,omitempty"`
+}
+
+type Resources []Resource

resources/resources.go

@@ -0,0 +1,105 @@
+// Package config provides methods for managing configuration of apps.
+package resources
+
+import (
+	"encoding/json"
+	"fmt"
+	drycc "github.com/drycc/controller-sdk-go"
+	"github.com/drycc/controller-sdk-go/api"
+)
+
+// List list an app's resources.
+func List(c *drycc.Client, appID string, results int) (api.Resources, int, error) {
+	u := fmt.Sprintf("/v2/apps/%s/resources/", appID)
+	body, count, reqErr := c.LimitedRequest(u, results)
+	if reqErr != nil && !drycc.IsErrAPIMismatch(reqErr) {
+		return []api.Resource{}, -1, reqErr
+	}
+	var resources []api.Resource
+	if err := json.Unmarshal([]byte(body), &resources); err != nil {
+		return []api.Resource{}, -1, err
+	}
+	return resources, count, reqErr
+}
+
+// Create create an app's resource.
+func Create(c *drycc.Client, appID string, resource api.Resource) (api.Resource, error) {
+	body, err := json.Marshal(resource)
+	if err != nil {
+		return api.Resource{}, err
+	}
+	u := fmt.Sprintf("/v2/apps/%s/resources/", appID)
+	res, reqErr := c.Request("POST", u, body)
+	if reqErr != nil {
+		return api.Resource{}, reqErr
+	}
+	defer res.Body.Close()
+	newResource := api.Resource{}
+	if err = json.NewDecoder(res.Body).Decode(&newResource); err != nil {
+		return api.Resource{}, err
+	}
+	return newResource, reqErr
+}
+
+// Get retrieves information about a resource
+func Get(c *drycc.Client, appID string, name string) (api.Resource, error) {
+	u := fmt.Sprintf("/v2/apps/%s/resources/%s/", appID, name)
+	res, reqErr := c.Request("GET", u, nil)
+	if reqErr != nil {
+		return api.Resource{}, reqErr
+	}
+	defer res.Body.Close()
+	resResource := api.Resource{}
+	if err := json.NewDecoder(res.Body).Decode(&resResource); err != nil {
+		return api.Resource{}, err
+	}
+	return resResource, reqErr
+}
+
+// Delete delete an app's resource.
+func Delete(c *drycc.Client, appID string, name string) error {
+	u := fmt.Sprintf("/v2/apps/%s/resources/%s/", appID, name)
+	res, err := c.Request("DELETE", u, nil)
+	if err == nil {
+		res.Body.Close()
+	}
+	return err
+}
+
+// Put update resource
+func Put(c *drycc.Client, appID string, name string, resource api.Resource) (api.Resource, error) {
+	body, err := json.Marshal(resource)
+	if err != nil {
+		return api.Resource{}, err
+	}
+	u := fmt.Sprintf("/v2/apps/%s/resources/%s/", appID, name)
+	res, reqErr := c.Request("PUT", u, body)
+	if reqErr != nil {
+		return api.Resource{}, reqErr
+	}
+	defer res.Body.Close()
+	newResource := api.Resource{}
+	if err = json.NewDecoder(res.Body).Decode(&newResource); err != nil {
+		return api.Resource{}, err
+	}
+	return newResource, reqErr
+}
+
+// Binding servicebinding binding with a serviceinstance
+func Binding(c *drycc.Client, appID string, name string, resource api.Binding) (api.Resource, error) {
+	body, err := json.Marshal(resource)
+	if err != nil {
+		return api.Resource{}, err
+	}
+	u := fmt.Sprintf("/v2/apps/%s/resources/%s/binding/", appID, name)
+	res, reqErr := c.Request("PATCH", u, body)
+	if reqErr != nil {
+		return api.Resource{}, reqErr
+	}
+	defer res.Body.Close()
+	newResource := api.Resource{}
+	if err = json.NewDecoder(res.Body).Decode(&newResource); err != nil {
+		return api.Resource{}, err
+	}
+	return newResource, reqErr
+}