add psw command stub

Author: Jeff McCormick

backupservice/backupservice.go

@@ -0,0 +1,60 @@
+package backupservice
+
+import (
+	"encoding/json"
+	log "github.com/Sirupsen/logrus"
+	"github.com/gorilla/mux"
+	"net/http"
+)
+
+type BackupDetail struct {
+	Name string
+}
+type ShowBackupResponse struct {
+	Items []BackupDetail
+}
+
+type CreateBackupRequest struct {
+	Name string
+}
+
+// pgo backup mycluster
+// parameters secretfrom
+func CreateBackupHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("backupservice.CreateBackupHandler called")
+	var request CreateBackupRequest
+	_ = json.NewDecoder(r.Body).Decode(&request)
+
+	log.Infoln("backupservice.CreateBackupHandler got request " + request.Name)
+}
+
+// pgo backup mycluster
+// pgo delete backup mycluster
+// parameters showsecrets
+// parameters selector
+// parameters namespace
+// parameters postgresversion
+// returns a ShowClusterResponse
+func ShowBackupHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("backupservice.ShowBackupHandler called")
+	vars := mux.Vars(r)
+	log.Infof(" vars are %v\n", vars)
+
+	switch r.Method {
+	case "GET":
+		log.Infoln("backupservice.ShowBackupHandler GET called")
+	case "DELETE":
+		log.Infoln("backupservice.ShowBackupHandler DELETE called")
+	}
+
+	w.WriteHeader(http.StatusOK)
+	w.Header().Set("Content-Type", "application/json")
+
+	resp := new(ShowBackupResponse)
+	resp.Items = []BackupDetail{}
+	c := BackupDetail{}
+	c.Name = "somecluster"
+	resp.Items = append(resp.Items, c)
+
+	json.NewEncoder(w).Encode(resp)
+}

client/cmd/apply.go

@@ -20,9 +20,6 @@ import (
 	"github.com/spf13/cobra"
 )
 
-var Selector string
-var DryRun bool
-
 var applyCmd = &cobra.Command{
 	Use:   "apply",
 	Short: "apply a Policy",

client/cmd/psw.go

@@ -0,0 +1,86 @@
+/*
+ Copyright 2017 Crunchy Data Solutions, Inc.
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+*/
+
+package cmd
+
+import (
+	"fmt"
+	log "github.com/Sirupsen/logrus"
+	//"github.com/crunchydata/postgres-operator/operator/util"
+	//"github.com/crunchydata/postgres-operator/tpr"
+	"github.com/spf13/cobra"
+	//"github.com/spf13/viper"
+	//"io/ioutil"
+	//kerrors "k8s.io/apimachinery/pkg/api/errors"
+	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	//"os/user"
+	//"strings"
+)
+
+var pswCmd = &cobra.Command{
+	Use:   "psw",
+	Short: "manage passwords",
+	Long: `PSW allows you to manage passwords across a set of clusters
+For example:
+
+pgo psw --selector=name=mycluster --update
+pgo psw --dry-run --selector=someotherpolicy
+.`,
+	Run: func(cmd *cobra.Command, args []string) {
+		log.Debug("psw called")
+		updatePasswords()
+	},
+}
+
+func init() {
+	RootCmd.AddCommand(pswCmd)
+
+	pswCmd.Flags().StringVarP(&Selector, "selector", "s", "", "The selector to use for cluster filtering ")
+	pswCmd.Flags().BoolVarP(&DryRun, "dry-run", "d", false, "--dry-run shows clusters and passwords that would be updated to but does not actually apply them")
+
+}
+
+func updatePasswords() {
+	//build the selector based on the selector parameter
+	//get the clusters list
+
+	//get filtered list of Deployments
+	var sel string
+	if Selector != "" {
+		sel = Selector + ",pg-cluster,!replica"
+	} else {
+		sel = "pg-cluster,!replica"
+	}
+	log.Infoln("selector string=[" + sel + "]")
+
+	lo := meta_v1.ListOptions{LabelSelector: sel}
+	deployments, err := Clientset.ExtensionsV1beta1().Deployments(Namespace).List(lo)
+	if err != nil {
+		log.Error("error getting list of deployments" + err.Error())
+		return
+	}
+
+	if DryRun {
+		fmt.Println("dry run only....")
+	}
+
+	for _, d := range deployments.Items {
+		fmt.Println("deployment : " + d.ObjectMeta.Name)
+		if !DryRun {
+		}
+
+	}
+
+}

client/cmd/root.go

@@ -35,6 +35,8 @@ var KubeconfigPath string
 var Labelselector string
 var DebugFlag bool
 var Namespace string
+var Selector string
+var DryRun bool
 
 // RootCmd represents the base command when called without any subcommands
 var RootCmd = &cobra.Command{

cloneservice/cloneservice.go

@@ -0,0 +1,27 @@
+package cloneservice
+
+import (
+	"encoding/json"
+	log "github.com/Sirupsen/logrus"
+	//"github.com/crunchydata/postgres-operator/tpr"
+	//"github.com/gorilla/mux"
+	"net/http"
+)
+
+type CloneResults struct {
+	Results []string
+}
+
+type CreateCloneRequest struct {
+	Name string
+}
+
+// pgo create clone
+// parameters secretfrom
+func CreateCloneHandler(w http.ResponseWriter, r *http.Request) {
+	log.Infoln("cloneservice.CreateCloneHandler called")
+	var request CreateCloneRequest
+	_ = json.NewDecoder(r.Body).Decode(&request)
+
+	log.Infoln("cloneservice.CreateCloneHandler got request " + request.Name)
+}

examples/operator/show-tpr.sh

@@ -0,0 +1,25 @@
+#!/bin/bash -x
+# Copyright 2016 Crunchy Data Solutions, Inc.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
+
+source $DIR/setup.sh
+
+$CO_CMD get pgbackups
+$CO_CMD get pgclones
+$CO_CMD get pgclusters
+$CO_CMD get pgpolicies 
+$CO_CMD get pgpolicylogs
+$CO_CMD get pgupgrades
+