add upgrade

Author: Jeff McCormick

clusterservice/scaleservice.go

@@ -0,0 +1,40 @@
+package clusterservice
+
+import (
+	"encoding/json"
+	log "github.com/Sirupsen/logrus"
+	//"github.com/crunchydata/postgres-operator/tpr"
+	"github.com/gorilla/mux"
+	"net/http"
+)
+
+type ScaleResponse struct {
+	Results string
+}
+
+type ScaleRequest struct {
+	Name string
+}
+
+// pgo scale mycluster --replica-count=1
+// parameters showsecrets
+// returns a ScaleResponse
+func ScaleClusterHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("clusterservice.ScaleClusterHandler called")
+	//log.Infoln("showsecrets=" + showsecrets)
+	vars := mux.Vars(r)
+	log.Infof(" vars are %v\n", vars)
+
+	switch r.Method {
+	case "GET":
+		log.Infoln("clusterservice.ScaleClusterHandler GET called")
+	}
+
+	w.WriteHeader(http.StatusOK)
+	w.Header().Set("Content-Type", "application/json")
+
+	resp := new(ScaleResponse)
+	resp.Results = "ok it worked"
+
+	json.NewEncoder(w).Encode(resp)
+}

restclient.go

@@ -5,8 +5,10 @@ import (
 	"encoding/json"
 	"fmt"
 	"github.com/crunchydata/postgres-operator/backupservice"
+	"github.com/crunchydata/postgres-operator/cloneservice"
 	"github.com/crunchydata/postgres-operator/clusterservice"
 	"github.com/crunchydata/postgres-operator/policyservice"
+	"github.com/crunchydata/postgres-operator/upgradeservice"
 	//"github.com/crunchydata/postgres-operator/tpr"
 	"log"
 	"net/http"
@@ -25,7 +27,11 @@ func main() {
 	//testShowCluster(true)
 	//testShowBackup(true)
 	//testShowPolicy(true)
-	testCreatePolicy()
+	//testCreatePolicy()
+	//testCreateClone()
+	//testScale()
+	testShowUpgrade(true)
+	testCreateUpgrade()
 
 }
 
@@ -232,3 +238,107 @@ func testCreatePolicy() {
 	fmt.Printf("%v\n", resp)
 
 }
+func testCreateClone() {
+	url := "http://localhost:8080/clones"
+
+	cl := new(cloneservice.CreateCloneRequest)
+	cl.Name = "newclone"
+	jsonValue, _ := json.Marshal(cl)
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonValue))
+	if err != nil {
+		log.Fatal("NewRequest: ", err)
+		return
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Fatal("Do: ", err)
+		return
+	}
+	fmt.Printf("%v\n", resp)
+
+}
+
+func testScale() {
+	url := "http://localhost:8080/clusters/scale/somename"
+
+	req, err := http.NewRequest("GET", url, nil)
+	if err != nil {
+		log.Fatal("NewRequest: ", err)
+		return
+	}
+
+	client := &http.Client{}
+
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Fatal("Do: ", err)
+		return
+	}
+	defer resp.Body.Close()
+
+	var response clusterservice.ScaleResponse
+	if err := json.NewDecoder(resp.Body).Decode(&response); err != nil {
+		log.Println(err)
+	}
+
+	fmt.Printf("test results %s\n", response.Results)
+
+}
+func testShowUpgrade(deleteFlag bool) {
+	url := "http://localhost:8080/upgrades/somename?showsecrets=true&other=thing"
+
+	action := "GET"
+	if deleteFlag {
+		action = "DELETE"
+		fmt.Println("doing delete")
+	}
+	req, err := http.NewRequest(action, url, nil)
+	if err != nil {
+		log.Fatal("NewRequest: ", err)
+		return
+	}
+
+	client := &http.Client{}
+
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Fatal("Do: ", err)
+		return
+	}
+
+	defer resp.Body.Close()
+
+	var response upgradeservice.ShowUpgradeResponse
+
+	if err := json.NewDecoder(resp.Body).Decode(&response); err != nil {
+		log.Println(err)
+	}
+
+	fmt.Println("Name = ", response.Items[0].Name)
+
+}
+func testCreateUpgrade() {
+	url := "http://localhost:8080/upgrades"
+
+	cl := new(upgradeservice.CreateUpgradeRequest)
+	cl.Name = "newupgrae"
+	jsonValue, _ := json.Marshal(cl)
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonValue))
+	if err != nil {
+		log.Fatal("NewRequest: ", err)
+		return
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Fatal("Do: ", err)
+		return
+	}
+	fmt.Printf("%v\n", resp)
+
+}

restserver.go

@@ -3,8 +3,10 @@ package main
 import (
 	log "github.com/Sirupsen/logrus"
 	"github.com/crunchydata/postgres-operator/backupservice"
+	"github.com/crunchydata/postgres-operator/cloneservice"
 	"github.com/crunchydata/postgres-operator/clusterservice"
 	"github.com/crunchydata/postgres-operator/policyservice"
+	"github.com/crunchydata/postgres-operator/upgradeservice"
 	"github.com/gorilla/mux"
 	"net/http"
 )
@@ -13,12 +15,16 @@ func main() {
 
 	log.Infoln("restserver starts")
 	r := mux.NewRouter()
+	r.HandleFunc("/clones", cloneservice.CreateCloneHandler)
 	r.HandleFunc("/policies", policyservice.CreatePolicyHandler)
 	r.HandleFunc("/policies/{name}", policyservice.ShowPolicyHandler).Methods("GET", "DELETE")
 	r.HandleFunc("/policies/apply/{name}", policyservice.ApplyPolicyHandler)
+	r.HandleFunc("/upgrades", upgradeservice.CreateUpgradeHandler)
+	r.HandleFunc("/upgrades/{name}", upgradeservice.ShowUpgradeHandler).Methods("GET", "DELETE")
 	r.HandleFunc("/clusters", clusterservice.CreateClusterHandler)
 	r.HandleFunc("/clusters/{name}", clusterservice.ShowClusterHandler).Methods("GET", "DELETE")
 	r.HandleFunc("/clusters/test/{name}", clusterservice.TestClusterHandler)
+	r.HandleFunc("/clusters/scale/{name}", clusterservice.ScaleClusterHandler)
 	r.HandleFunc("/backups/{name}", backupservice.ShowBackupHandler).Methods("GET", "DELETE")
 	log.Fatal(http.ListenAndServe(":8080", r))
 }

upgradeservice/upgradeservice.go

@@ -0,0 +1,68 @@
+package upgradeservice
+
+import (
+	"encoding/json"
+	log "github.com/Sirupsen/logrus"
+	//"github.com/crunchydata/postgres-operator/tpr"
+	"github.com/gorilla/mux"
+	"net/http"
+)
+
+type UpgradeDetail struct {
+	Name string
+	//deployments
+	//replicasets
+	//pods
+	//services
+	//secrets
+}
+type ShowUpgradeResponse struct {
+	Items []UpgradeDetail
+}
+
+type CreateUpgradeRequest struct {
+	Name string
+}
+
+// pgo upgrade mycluster
+// parameters --upgrade-type
+// parameters --ccp-image-tag
+func CreateUpgradeHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("upgradeservice.CreateUpgradeHandler called")
+	var request CreateUpgradeRequest
+	_ = json.NewDecoder(r.Body).Decode(&request)
+
+	log.Infoln("upgradeservice.CreateUpgradeHandler got request " + request.Name)
+}
+
+// pgo show upgrade
+// pgo delete myupgrade
+// parameters showsecrets
+// parameters selector
+// parameters namespace
+// parameters postgresversion
+// returns a ShowUpgradeResponse
+func ShowUpgradeHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("upgradeservice.ShowUpgradeHandler called")
+	//log.Infoln("showsecrets=" + showsecrets)
+	vars := mux.Vars(r)
+	log.Infof(" vars are %v\n", vars)
+
+	switch r.Method {
+	case "GET":
+		log.Infoln("upgradeservice.ShowUpgradeHandler GET called")
+	case "DELETE":
+		log.Infoln("upgradeservice.ShowUpgradeHandler DELETE called")
+	}
+
+	w.WriteHeader(http.StatusOK)
+	w.Header().Set("Content-Type", "application/json")
+
+	resp := new(ShowUpgradeResponse)
+	resp.Items = []UpgradeDetail{}
+	c := UpgradeDetail{}
+	c.Name = "someupgrade"
+	resp.Items = append(resp.Items, c)
+
+	json.NewEncoder(w).Encode(resp)
+}